sinan/plexus
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat: I have implemented the core Web3 economy features for Plexus, aligning it with the "Club 2.0" vision.

Browse Source
This commit is contained in:
Sinan
2026-01-15 21:38:02 +01:00
parent 712f62f7ae
commit 64060f6a01
10 changed files with 1819 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
server/db.js
View File

@@ -13,6 +13,7 @@ con.exec(`
username VARCHAR UNIQUE,
bio VARCHAR DEFAULT '',
banner_color VARCHAR DEFAULT '#6366f1',
balance INTEGER DEFAULT 100,
last_seen TIMESTAMP
);
@@ -73,6 +74,13 @@ con.exec(`
if (err) console.error("Error adding banner_color column:", err);
});
}
const hasBalance = rows.some(r => r.name === 'balance');
if (!hasBalance) {
con.run("ALTER TABLE users ADD COLUMN balance INTEGER DEFAULT 100", (err) => {
if (err) console.error("Error adding balance column:", err);
});
}
});
console.log('Database initialized and cleared');
});

71
server/index.js
View File

@@ -58,6 +58,21 @@ io.on('connection', (socket) => {
uStmt.finalize();
if (err) console.error("Update error:", err);
socket.emit('usernameUpdated', { username: existingUsername });
// Send balance
con.prepare(`SELECT balance FROM users WHERE wallet_address = ?`, (err, bStmt) => {
if (err) return console.error("Balance prepare error:", err);
bStmt.all(walletAddress, (err, bRows) => {
bStmt.finalize();
if (err) return console.error("Balance fetch error:", err);
if (bRows.length > 0) {
socket.emit('balanceUpdated', { balance: bRows[0].balance });
} else {
console.error("No user found for balance fetch");
}
});
});
broadcastUserList();
});
});
@@ -80,6 +95,7 @@ io.on('connection', (socket) => {
iStmt.finalize();
if (err) console.error("Insert error:", err);
socket.emit('usernameUpdated', { username: finalUsername });
socket.emit('balanceUpdated', { balance: 100 }); // Default balance
broadcastUserList();
});
});
@@ -113,6 +129,27 @@ io.on('connection', (socket) => {
console.log(`Username updated for ${walletAddress} to ${newUsername}`);
socket.emit('usernameUpdated', { username: newUsername });
// Deduct 30 PLEXUS
con.prepare(`UPDATE users SET balance = balance - 30 WHERE wallet_address = ?`, (err, bStmt) => {
if (!err) {
bStmt.run(walletAddress, () => {
bStmt.finalize();
// Fetch new balance
con.prepare(`SELECT balance FROM users WHERE wallet_address = ?`, (err, sStmt) => {
if (!err) {
sStmt.all(walletAddress, (err, rows) => {
sStmt.finalize();
if (!err && rows.length > 0) {
socket.emit('balanceUpdated', { balance: rows[0].balance });
}
});
}
});
});
}
});
broadcastUserList();
// Also broadcast a system message about the change
@@ -139,6 +176,40 @@ io.on('connection', (socket) => {
con.prepare(`INSERT INTO messages (id, channel_id, wallet_address, content, timestamp, tx_id)
VALUES (nextval('seq_msg_id'), ?, ?, ?, ?, ?) RETURNING id`, (err, stmt) => {
if (err) return console.error("Prepare error:", err);
// Deduct 1 PLEXUS
con.prepare(`UPDATE users SET balance = balance - 1 WHERE wallet_address = ? AND balance >= 1`, (err, bStmt) => {
if (err) return console.error("Balance update error:", err);
bStmt.run(walletAddress, function (err) { // Use function to get this.changes
bStmt.finalize();
if (err) return console.error("Balance deduct error:", err);
// If no rows updated, balance was too low (though client should prevent this)
// We proceed anyway for now as we don't have easy rollback here without transactions,
// but in a real app we'd check first.
// Fetch new balance to sync client
con.prepare(`SELECT balance FROM users WHERE wallet_address = ?`, (err, sStmt) => {
if (!err) {
sStmt.all(walletAddress, (err, rows) => {
sStmt.finalize();
if (!err && rows.length > 0) {
// Emit to specific socket if possible, or broadcast?
// We don't have the socket object here easily unless we map wallet -> socket
// But we can just rely on client optimistic update for now, or...
// Let's try to find the socket
for (const [sid, wallet] of connectedSockets.entries()) {
if (wallet === walletAddress) {
io.to(sid).emit('balanceUpdated', { balance: rows[0].balance });
}
}
}
});
}
});
});
});
stmt.all(channelId, walletAddress, content, timestamp, txId, (err, rows) => {
stmt.finalize();
if (err) {

67
server/tests/token.test.js Normal file
View File

@@ -0,0 +1,67 @@
const { expect } = require('chai');
const io = require('socket.io-client');
const SERVER_URL = 'http://localhost:3000';
describe('Token Economy', function () {
this.timeout(5000);
let socket;
const walletAddress = 'TokenTestWallet_' + Date.now();
const username = 'TokenUser_' + Date.now();
before((done) => {
// Ensure server is running (assuming it's started externally or we rely on it)
// For this test, we assume the server is running on port 3000 as per package.json start script
// If not, we might need to start it here, but usually integration tests assume environment
socket = io(SERVER_URL);
socket.on('connect', done);
});
after((done) => {
if (socket.connected) {
socket.disconnect();
}
done();
});
it('should initialize user with 100 PLEXUS', (done) => {
socket.emit('join', { walletAddress, username });
socket.once('balanceUpdated', (data) => {
expect(data.balance).to.equal(100);
done();
});
});
it('should deduct 1 PLEXUS when sending a message', (done) => {
// Wait for join to complete if not already
// We can just emit sendMessage, but we need to be sure we are joined?
// The previous test joined, so we should be good.
const channelId = 'nebula';
const content = 'Hello World';
const txId = 'TX_TEST_' + Date.now();
// Listen for balance update
socket.once('balanceUpdated', (data) => {
expect(data.balance).to.equal(99);
done();
});
socket.emit('sendMessage', { channelId, walletAddress, content, txId });
});
it('should deduct 30 PLEXUS when changing username', (done) => {
const newUsername = 'RichUser_' + Date.now();
const txId = 'TX_NAME_' + Date.now();
socket.once('balanceUpdated', (data) => {
// 99 - 30 = 69
expect(data.balance).to.equal(69);
done();
});
socket.emit('updateUsername', { walletAddress, newUsername, txId });
});
});