-
Notifications
You must be signed in to change notification settings - Fork 135
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
feat: Publishing serviceEndpoint to DID Doc
- Loading branch information
1 parent
a6a1e94
commit a9fb385
Showing
15 changed files
with
450 additions
and
231 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1 @@ | ||
| secrets |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,39 @@ | ||
| import * as Daf from 'daf-core' | ||
| import { core } from './framework' | ||
|
|
||
| export const getIdentity = async () => { | ||
| // Get of create new identity | ||
| let identity: Daf.AbstractIdentity | ||
| const identities = await core.identityManager.getIdentities() | ||
| if (identities.length > 0) { | ||
| identity = identities[0] | ||
| } else { | ||
| const identityProviders = await core.identityManager.getIdentityProviderTypes() | ||
| identity = await core.identityManager.createIdentity(identityProviders[0].type) | ||
| } | ||
|
|
||
| return identity | ||
| } | ||
|
|
||
| export const setServiceEndpoint = async (identity: Daf.AbstractIdentity, serviceEndpoint: string) => { | ||
| // Check if DID Document contains current serviceEndpoint | ||
| const didDoc = await core.didResolver.resolve(identity.did) | ||
| const exists = didDoc?.service?.find(item => item.serviceEndpoint === serviceEndpoint) | ||
| if (!exists) { | ||
| try { | ||
| const txHash = await identity.identityController.addService({ | ||
| id: 'any', | ||
| type: 'Messaging', | ||
| serviceEndpoint, | ||
| }) | ||
| if (txHash) { | ||
| console.log('New service endpoint published. Tx Hash:', txHash) | ||
| return true | ||
| } | ||
| } catch (e) { | ||
| console.log(e) | ||
| } | ||
| return false | ||
| } | ||
| return true | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,224 @@ | ||
| import express from 'express' | ||
| import * as Daf from 'daf-core' | ||
| import * as SD from 'daf-selective-disclosure' | ||
| import * as W3C from 'daf-w3c' | ||
| import { app, server, io, sessionStore } from './server' | ||
| import { core, dataStore } from './framework' | ||
| import { getIdentity, setServiceEndpoint } from './identity' | ||
|
|
||
| import Debug from 'debug' | ||
| const debug = Debug('main') | ||
|
|
||
| if (!process.env.HOST) throw Error('Environment variable HOST not set') | ||
| if (!process.env.PORT) throw Error('Environment variable PORT not set') | ||
|
|
||
| async function main() { | ||
| await dataStore.initialize() | ||
| const identity = await getIdentity() | ||
|
|
||
| const messagingEndpoint = '/handle-message' | ||
| const serviceEndpoint = process.env.HOST + messagingEndpoint | ||
|
|
||
| const result = await setServiceEndpoint(identity, serviceEndpoint) | ||
| if (!result) { | ||
| throw Error('Service endpoint not published. You probably need to send some ETH to ' + identity.did) | ||
| } | ||
|
|
||
| app.post(messagingEndpoint, express.text({ type: '*/*' }), async (req, res) => { | ||
| try { | ||
| // This will trigger Daf.EventTypes.validatedMessage | ||
| const result = await core.validateMessage( | ||
| new Daf.Message({ raw: req.body, meta: { type: 'serviceEndpoint', id: serviceEndpoint } }), | ||
| ) | ||
| res.json({ id: result.id }) | ||
| } catch (e) { | ||
| res.send(e.message) | ||
| } | ||
| }) | ||
|
|
||
| core.on(Daf.EventTypes.validatedMessage, async (message: Daf.Message) => { | ||
| await dataStore.saveMessage(message) | ||
|
|
||
| if (message.type === W3C.MessageTypes.vp && message.threadId) { | ||
| // TODO check for required vcs | ||
|
|
||
| const sessionId = message.threadId | ||
| io.in(sessionId).emit('loggedin', { did: message.sender }) | ||
|
|
||
| sessionStore.get(sessionId, (error, session) => { | ||
| if (error) throw Error(error) | ||
|
|
||
| if (session) { | ||
| session.did = message.sender | ||
| sessionStore.set(sessionId, session) | ||
| } | ||
| }) | ||
| } | ||
| }) | ||
|
|
||
| const requireLogin = (req: express.Request, res: express.Response, next: express.NextFunction) => { | ||
| if (!req.session) throw Error('Session not configured') | ||
| if (!req.session.did) { | ||
| res.redirect('/login') | ||
| } else { | ||
| next() | ||
| } | ||
| } | ||
|
|
||
| app.get('/', requireLogin, async (req, res) => { | ||
| res.redirect('/home') | ||
| }) | ||
|
|
||
| app.get('/home', requireLogin, async (req, res) => { | ||
| if (!req.session) throw Error('Session not configured') | ||
|
|
||
| // Counting views to show that session is working | ||
| req.session.views = req.session.views ? req.session.views + 1 : 1 | ||
|
|
||
| const { did, views } = req.session | ||
| const name = await dataStore.shortId(did) | ||
| res.render('home', { did, views, name }) | ||
| }) | ||
|
|
||
| app.get('/history', requireLogin, async (req, res) => { | ||
| if (!req.session) throw Error('Session not configured') | ||
|
|
||
| // Counting views to show that session is working | ||
| req.session.views = req.session.views ? req.session.views + 1 : 1 | ||
|
|
||
| const { did, views } = req.session | ||
| const name = await dataStore.shortId(did) | ||
| const messages = await dataStore.findMessages({ sender: did }) | ||
| console.log(messages) | ||
| res.render('history', { did, views, name, messages }) | ||
| }) | ||
|
|
||
| app.get('/login', async (req, res) => { | ||
| if (!req.session) throw Error('Session not configured') | ||
|
|
||
| // Counting views to show that session is working | ||
| req.session.views = req.session.views ? req.session.views + 1 : 1 | ||
|
|
||
| // Sign Selective Disclosure Request | ||
| const jwt = await core.handleAction({ | ||
| type: SD.ActionTypes.signSdr, | ||
| did: identity.did, | ||
| data: { | ||
| tag: req.sessionID, | ||
| claims: [ | ||
| { | ||
| reason: 'We need this information', | ||
| essential: true, | ||
| claimType: 'name', | ||
| }, | ||
| ], | ||
| }, | ||
| } as SD.ActionSignSdr) | ||
|
|
||
| const url = encodeURI(process.env.HOST + '/?c_i=') + jwt | ||
|
|
||
| res.render('login', { views: req.session.views, url }) | ||
| }) | ||
|
|
||
| app.get('/credential', requireLogin, async (req, res) => { | ||
| if (!req.session) throw Error('Session not configured') | ||
|
|
||
| // Counting views to show that session is working | ||
| req.session.views = req.session.views ? req.session.views + 1 : 1 | ||
|
|
||
| const { did, views } = req.session | ||
| const name = await dataStore.shortId(did) | ||
|
|
||
| // Sign verifiable credential | ||
| const nameJwt = await core.handleAction({ | ||
| type: W3C.ActionTypes.signVc, | ||
| did: identity.did, | ||
| data: { | ||
| sub: did, | ||
| vc: { | ||
| '@context': ['https://www.w3.org/2018/credentials/v1'], | ||
| type: ['VerifiableCredential'], | ||
| credentialSubject: { | ||
| name, | ||
| }, | ||
| }, | ||
| }, | ||
| } as W3C.ActionSignW3cVc) | ||
|
|
||
| const kwcJwt = await core.handleAction({ | ||
| type: W3C.ActionTypes.signVc, | ||
| did: identity.did, | ||
| data: { | ||
| sub: did, | ||
| vc: { | ||
| '@context': ['https://www.w3.org/2018/credentials/v1'], | ||
| type: ['VerifiableCredential'], | ||
| credentialSubject: { | ||
| kycId: '123XZY', | ||
| }, | ||
| }, | ||
| }, | ||
| } as W3C.ActionSignW3cVc) | ||
|
|
||
| const vpJwt = await core.handleAction({ | ||
| type: W3C.ActionTypes.signVp, | ||
| did: identity.did, | ||
| data: { | ||
| sub: did, | ||
| vp: { | ||
| '@context': ['https://www.w3.org/2018/credentials/v1'], | ||
| type: ['VerifiableCredential'], | ||
| verifiableCredential: [nameJwt, kwcJwt], | ||
| }, | ||
| }, | ||
| } as W3C.ActionSignW3cVp) | ||
|
|
||
| const url = encodeURI(process.env.HOST + '/?c_i=') + vpJwt | ||
|
|
||
| res.render('credential', { views, url }) | ||
| }) | ||
|
|
||
| app.get('/about', async (req, res) => { | ||
| if (!req.session) throw Error('Session not configured') | ||
|
|
||
| // Counting views to show that session is working | ||
| req.session.views = req.session.views ? req.session.views + 1 : 1 | ||
|
|
||
| const { views } = req.session | ||
|
|
||
| // Sign verifiable credential | ||
| const jwt = await core.handleAction({ | ||
| type: W3C.ActionTypes.signVc, | ||
| did: identity.did, | ||
| data: { | ||
| sub: identity.did, | ||
| vc: { | ||
| '@context': ['https://www.w3.org/2018/credentials/v1'], | ||
| type: ['VerifiableCredential'], | ||
| credentialSubject: { | ||
| name: 'DAF Demo', | ||
| description: 'Demo application', | ||
| profileImage: 'https://i.imgur.com/IMn3dIg.png', | ||
| }, | ||
| }, | ||
| }, | ||
| } as W3C.ActionSignW3cVc) | ||
|
|
||
| const url = encodeURI(process.env.HOST + '/?c_i=') + jwt | ||
|
|
||
| res.render('about', { views, url }) | ||
| }) | ||
|
|
||
| app.get('/logout', (req, res) => req.session?.destroy(() => res.redirect('/'))) | ||
|
|
||
| server.listen(process.env.PORT, async () => { | ||
| console.log(`Server running at http://localhost:${process.env.PORT}/`) | ||
| console.log(`Messaging service endpoint ${serviceEndpoint}`) | ||
|
|
||
| // await core.setupServices() | ||
| // await core.listen() | ||
| // await core.getMessagesSince(await dataStore.latestMessageTimestamps()) | ||
| }) | ||
| } | ||
|
|
||
| main().catch(e => console.log(e.message)) |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,38 @@ | ||
| import express from 'express' | ||
| import session, { MemoryStore } from 'express-session' | ||
| import socketio from 'socket.io' | ||
| import http from 'http' | ||
| import handlebars from 'express-handlebars' | ||
| import sharedSession from 'express-socket.io-session' | ||
|
|
||
| const app = express() | ||
| app.engine('handlebars', handlebars()) | ||
| app.set('view engine', 'handlebars') | ||
| app.use(express.text()) | ||
|
|
||
| const sessionStore = new MemoryStore() | ||
| const sess = session({ | ||
| secret: 'keyboard cat', | ||
| cookie: { maxAge: 10 * 60000 }, | ||
| saveUninitialized: true, | ||
| resave: true, | ||
| store: sessionStore, | ||
| }) | ||
| app.use(sess) | ||
|
|
||
| const server = http.createServer(app) | ||
| const io = socketio(server) | ||
|
|
||
| io.use( | ||
| sharedSession(sess, { | ||
| autoSave: true, | ||
| }), | ||
| ) | ||
|
|
||
| io.on('connection', function(socket) { | ||
| if (socket.handshake?.session) { | ||
| socket.join(socket.handshake.session.id) | ||
| } | ||
| }) | ||
|
|
||
| export { app, server, io, sessionStore } |
Oops, something went wrong.