indexUCP.ts

import {createAccount, DemoUCPAgent, getAuthenticatedSession, instantiateCSS, sleep, SubscriptionEnum} from "./src";
import {DataFactory, Store, Writer} from "n3";
import {ACL, RDF} from "@solid/community-server";
import namedNode = DataFactory.namedNode;

const baseURL = "http://localhost:3000/"
const policyContainer = baseURL + "policies/"
const webID = "https://woslabbi.pod.knows.idlab.ugent.be/profile/card#me"
const resource = "http://localhost:3000/ldes"

const agentPort = 3123
const agentBaseUrl = `http://localhost:${agentPort}/`
const solidAgentPodName = 'solid'
const solidAgentWW = "as;dklfje"
const solidAgentMail = "solid@SolidAgent.css"
const solidAgentWebID = `${agentBaseUrl}${solidAgentPodName}/profile/card#me`

async function ucpInitialisation() {
    // create resource
    await fetch(resource, {
        method: "PUT",
        headers: {
            "content-type": "text/turtle"
        },
        body: "<http://localhost:3000/ldes> a <https://w3id.org/ldes#EventStream>."
    })

    // change the ACL of the resource such that nobody has access to it and the agent can control access.
    const aclStore = new Store()
    const aclResourceURL = resource + '.acl'
    const agentAuthorization = namedNode(aclResourceURL + '#AgentAuthorization') // hash value should be uuid in future?
    aclStore.addQuad(agentAuthorization, RDF.terms.type, ACL.terms.Authorization)
    aclStore.addQuad(agentAuthorization, ACL.terms.agent, namedNode(solidAgentWebID))
    aclStore.addQuad(agentAuthorization, ACL.terms.mode, ACL.terms.Control)
    aclStore.addQuad(agentAuthorization, ACL.terms.accessTo, namedNode(resource))
    aclStore.addQuad(agentAuthorization, ACL.terms.default, namedNode(resource))

    await fetch(aclResourceURL, {
        method: "PUT",
        headers: {
            "content-type": "text/turtle"
        },
        body: new Writer().quadsToString(aclStore.getQuads(null, null, null, null))
    })

    // create policy container
    await fetch(policyContainer, {
        method: "PUT"
    })

    // setup CSS with idp for agent
    const app = await instantiateCSS(agentPort)
    await app.start();

    // create account for agent
    await createAccount(agentBaseUrl, {email: solidAgentMail, password: solidAgentWW, podName: solidAgentPodName})
    await sleep(500)
}

async function ucpDemo() {
    // set up CSS: $ npx community-solid-server -c memory-no-setup.json

    // initialise resource + policy container
    await ucpInitialisation()
    // testing auth
    const session = await getAuthenticatedSession({
        webId: solidAgentWebID,
        email: solidAgentMail,
        password: solidAgentWW
    })
    console.log(`Account (${solidAgentWebID}) created and logged in`, session.info.isLoggedIn)
    // const res = await session.fetch(resource+'.acl')
    // console.log(await res.text())
    const demo = new DemoUCPAgent({
        solid: {
            solidResources: [policyContainer],
            subscriptionType: {type: SubscriptionEnum.PUSH},
            session: session
        }
    })
    // note: listening to the policies container works through using SolidContainerNotificationClient -> Though no reasoning is executed right now (12/06/2023).
    //  -> fixed by changing the rule and by updating koreografeye to v0.3.2
    await demo.start()


    // curl --data "@/home/wouts/Documents/repos/Agent/Solid-Agent/rules/usage-control/durationPermissionPolicy.ttl" http://localhost:3000/ -H "content-type: text/turtle"
}

ucpDemo()
// step 1: set up server
// $ npx community-solid-server -c memory-no-setup.json
// step 2: set up demoUCPAgent (running this code)
// $ npx ts-node indexUCP.ts
// step 3: send curl request of durationPermissionPolicy
// $ curl --data "@./rules/usage-control/durationPermissionPolicy.ttl" http://localhost:3000/policies -H "content-type: text/turtle"