ag-auth

import { AGServer } from 'socketcluster-server'; import { AuthEngine } from 'ag-auth'; // Although usually accessed via agServer.auth const SECRET_KEY = process.env.AUTH_SECRET_KEY ?? 'my-secret-key-123'; const agServer = new AGServer({ authKey: SECRET_KEY, // If you were to override the default auth engine, you might do: // authEngine: new AuthEngine(SECRET_KEY) }); (async () => { for await (const { socket } of agServer.listen()) { (async () => { // This is how ag-auth functionality is typically accessed // via the agServer instance. const tokenData = { username: 'testuser', roles: ['admin'] }; try { // Sign a token using the configured authEngine (ag-auth) const token = await agServer.auth.signToken(tokenData, { expiresIn: '1h' }); console.log(`Signed JWT: ${token}`); // Simulate client sending token and server verifying socket.on('login', async (data) => { try { const decodedToken = await agServer.auth.verifyToken(data.token); console.log(`Socket ${socket.id} authenticated:`, decodedToken); socket.emit('authSuccess', { message: 'Authenticated successfully', user: decodedToken.username }); } catch (error) { console.error(`Socket ${socket.id} authentication failed:`, error.message); socket.emit('authFail', { message: 'Authentication failed', error: error.message }); } }); // Example: Client attempts to log in setTimeout(() => { console.log('Simulating client login attempt...'); socket.emit('login', { token: token }); }, 1000); } catch (error) { console.error('Error during auth setup:', error); } })(); } })(); console.log('SocketCluster server is listening for connections...');