Stało się! Ostatnia część najlepszej serii. Zostało dodać p2p i synchronizację. Warto się zapoznać z https://blog.patys.pl/2018/09/10/p2p-komunikacja-serwerow-nodejs-z-wykorzystaniem-websockets/ Będziemy bazować na tym artykule.
Od tego będzie najprościej zacząć: https://expressjs.com/en/starter/hello-world.html. Na podstawie przykładu dodamy tylko swoje końcówki, czyli:
Root/Home (zależy kto jak nazywa):
app.get('/', (req, res) => {
res.send(\`numberOfBlocks: ${patyscoin.blockchain.length}
difficulty: ${patyscoin.difficulty},\`);
});
Wyświetli nam liczbę bloków i trudność.
Connect:
app.get('/connect/:address', (req, res) => {
p2p.addNewConnection(req.params.address);
res.redirect('/');
});
Posłuży do stworzenia nowego połączenia z innym serwerem.
Block:
app.get('/block/:blockNr', (req, res) =>
res.json(patyscoin.blockchain[req.params.blockNr]));
Wyświetli nam blok o wybranym numerze i zwróci jego json.
Transactions:
app.get('/transactions', (req, res) =>
res.json(patyscoin.transactions));
Pokaże listę oczekujących transakcji w json.
Test:
app.get('/test', (req, res) => {
p2p.broadcast({ type: 'TRANSACTION', data: transaction });
patyscoin.addTransaction(fromJSON(JSON.parse(transaction)));
res.redirect('/');
});
Doda nam testową transakcję do blockchain.
Mine:
app.get('/mine', (req, res) => {
patyscoin.addBlock();
res.redirect('/');
});
Wykopie nowy blok. Robimy to poprzez ręczne uruchomienie kopania w ramach testów. Daje większą kontrolę żeby zobaczyć jak działa nasz blockchain.
Jak przyjrzymy się powyższym końcówkom potrzebujemy dwie rzeczy. “p2p” oraz “patyscoin”. Drugi z tych elementów już mamy, czyli nasz blockchain stworzony w poprzednich artykułach. Zostaje nam połączenie między serwerami.
Tworząc to napotkałem spory problem. Pewnie źle do tego podszedłem, ale w sumie potrzebowałem p2p i blockchain w każdym pliku odpowiadającym za połączenie i wpadłem w nazwijmy to “require hell” - https://stackoverflow.com/questions/23341883/can-node-modules-require-each-other. p2p i blockchain potrzebowały dołączać się razem i byłem zmuszony zrobić p2pBridge, który połączy nam blockchain oraz p2p.
Tutaj pojawił się problem. Jak zrobić to najprościej. Zdecydowałem się dodać coś w stylu “subscribe pattern”. Jednak poszło mi to dosyć nieudolnie. Próbowałem zrobić to samemu nie sprawdzając dokładnie istniejących rozwiązań i popełniłem spory błąd. Nauczka na przyszłość: zawsze robić research jeśli tworzysz coś co ma zapewne wzorzec. (Tutaj jest jak powinno to mniej więcej wyglądać: https://gist.github.com/learncodeacademy/777349747d8382bfb722). A oto moja implementacja:
const patyscoin = require('./index');
const { fromJSON } = require('./src/transactionBuilder');
const p2p = require('./p2p');
const onNewTransaction = (data) => {
let transaction;
try {
transaction = fromJSON(JSON.parse(data));
} catch(e) {
transaction = fromJSON(data);
}
patyscoin.addTransaction(transaction);
}
const onNewBlock = (data) => {
let block;
try {
block = patyscoin.blockFromJSON(JSON.parse(data));
} catch(e) {
block = patyscoin.blockFromJSON(data);
}
patyscoin.addBlock(block);
}
const broadcastNewTransaction = (transaction) => {
p2p.broadcast({ type: 'TRANSACTION', data: transaction });
}
const broadcastNewBlock = (block) => {
p2p.broadcast({ type: 'BLOCK', data: block });
}
const init = () => {
patyscoin.subscribe(broadcastNewTransaction, broadcastNewBlock);
p2p.subscribe(onNewTransaction, onNewBlock);
}
module.exports = { init };
Jak widać najważniejsza jest funkcja "init". Dodaje do patyscoin oraz p2p wszystkie wymienione wyżej funkcje. Czyli blockchain (patyscoin) może reagować na transakcje i je rozsyłać oraz p2p może dodawać bloki i transakcje jeśli takie przyjdą.
Przejdźmy na początek do blockchain i przyjrzyjmy się funkcji “subscribe”.
subscribe(newTransaction, newBlock) {
this.newTransactionCreated = newTransaction;
this.newBlockCreated = newBlock;
}
Jak widzimy przypisuje funkcje do blockchain. W ten sposób blockchain może reagować, kiedy jest dodana transakcja lub blok i pokazać to światu. Na przykład transakcja:
addTransaction(newTransaction) {
if (this.checkTransaction(newTransaction)) {
this.transactions.push(newTransaction);
if(this.newTransactionCreated) {
this.newTransactionCreated(newTransaction);
}
console.info(`Transaction added: ${newTransaction.id}`)
} else {
console.error(`Cannot add transaction`);
}
}
Lub blok:
addBlock(newBlock = null) {
let block;
if (!newBlock) {
block = this.mineNewBlock();
} else {
block = newBlock;
}
if (this.validateBlock(block)) {
this.blockchain.push(block);
if (this.newBlockCreated) {
this.newBlockCreated(block);
}
} else console.error('invalid block!')
}
Dzięki temu odpalą się odpowiednie funkcje, czyli broadcastNewTransaction oraz broadcastNewBlock
Teraz czas zobaczyć jak p2p przekazuje informacje. Zasada działania jest taka sama.
/*
{ type: 'TRANSACTION', data: string }
{ type: 'SOCKETS', addresses: array }
*/
ws.on('message', (data) => {
const message = JSON.parse(data);
switch(message.type) {
case 'TRANSACTION':
onNewTransaction && onNewTransaction(message.data);
console.log('New transaction');
break;
case 'BLOCK':
onNewBlock && onNewBlock(message.data);
console.log('New block');
break;
case 'SOCKETS':
const newConnections = message.addresses.filter(add => !addresses.includes(add));
newConnections.forEach((con) => {
addNewConnection(con);
});
break;
default:
break;
}
});
};
Jak widzimy odpowiednia funkcja jest uruchamiana w zależności co zostanie przesłane. Gdy otrzymamy message z typem “TRANSACTION” to uruchomimy funkcję “onNewTransaction” jeśli istnieje.
Spójrzmy wyżej w implementację subscribe. Widzimy, że dane są parsowane i dodawane do blockchain.
To jest kawał kodu, z którego nie jestem dumny. Jest brzydki, ma dużo zależności i nie tak się powinno programować. To kod, który działa. Zdecydowałem się go opublikować, bo to jest pierwsza rzecz napisana jaka przyszła mi do głowy. Zasada była robić jak najszybciej i najprościej.
Powoli kończymy serię. Pojawią się tutaj jeszcze dodatki, jako kolejne posty mające na celu usprawnić i uzupełnić całą wiedzę potrzebną do stworzenia najprostszego blockchain. Podsumujmy co zrobiliśmy przez te wszystkie posty:
Zajęło mi to rok czasu. Nie robiłem tego fulltime ani za pieniądze. Po prostu w wolnych chwilach jako pasja. Żeby nie zatrzymywać się poszerzałem swoją wiedzę o inne przykłady i formy blockchain: https://blog.patys.pl/category/kryptowaluty/
Ruszyłem z informacjami dla początkujących, żeby unormować wiedzę: https://blog.patys.pl/category/krypto/
Wymagało to dużo samozaparcia i motywacji. Zajęło dużo czasu, ale się udało. Skończyłem to i ruszam dalej. Z nowym projektem i pomysłem.
Dam radę!!