update-manager-n3patch-insert-test.ts

import * as chai from 'chai'
import { Headers } from 'cross-fetch'
import * as dirtyChai from 'dirty-chai'
import * as sinon from 'sinon'
import * as sinonChai from 'sinon-chai'
import { blankNode, Fetcher, graph, lit, namedNode, st, sym, UpdateManager } from '../../src/index'
import BlankNode from '../../src/blank-node';


const { expect } = chai

chai.use((sinonChai as any).default)
chai.use((dirtyChai as any).default)

chai.should()

describe('n3-patch updates via update manager', () => {

    const subject = sym('https://pod.example/test/foo#subject')
    const predicate = sym('https://pod.example/test/foo#predicate')
    let fetchMock;
    let store;
    let updater;

    beforeEach(() => {
        store = graph();
        fetchMock = sinon.stub().resolves({
            ok: true,
            status: 200,
            statusText: 'OK',
            headers: new Headers({
                'accept-patch': 'text/n3'
            })
        });
        store.fetcher = new Fetcher(store, { fetch: fetchMock })
        updater = new UpdateManager(store)
    });

    it('calls PATCH to insert a triple', async () => {
        const st1 = st(subject, predicate, lit("literal value"), subject.doc())
        await updater.update([], [st1])
        expect(getPatchCall().lastArg.body).to.equal(`
@prefix solid: <http://www.w3.org/ns/solid/terms#>.
@prefix ex: <http://www.example.org/terms#>.

_:patch

      solid:inserts {
        <https://pod.example/test/foo#subject> <https://pod.example/test/foo#predicate> "literal value" .
      };   a solid:InsertDeletePatch .
`)
    })

    it('calls PATCH to insert a triple including line feed', async () => {
        const st1 = st(subject, predicate, lit("literal\nvalue"), subject.doc())
        await updater.update([], [st1])
        expect(getPatchCall().lastArg.body).to.equal(`
@prefix solid: <http://www.w3.org/ns/solid/terms#>.
@prefix ex: <http://www.example.org/terms#>.

_:patch

      solid:inserts {
        <https://pod.example/test/foo#subject> <https://pod.example/test/foo#predicate> "literal\\nvalue" .
      };   a solid:InsertDeletePatch .
`)
    })

    it('calls PATCH to insert a triple including carriage return line feed', async () => {
        const st1 = st(subject, predicate, lit("literal\r\nvalue"), subject.doc())
        await updater.update([], [st1])
        expect(getPatchCall().lastArg.body).to.equal(`
@prefix solid: <http://www.w3.org/ns/solid/terms#>.
@prefix ex: <http://www.example.org/terms#>.

_:patch

      solid:inserts {
        <https://pod.example/test/foo#subject> <https://pod.example/test/foo#predicate> "literal\\r\\nvalue" .
      };   a solid:InsertDeletePatch .
`)
    })

    it('does not anonymize triples in INSERT DATA query', async () => {
        const bNode = new BlankNode('subj');
        const st1 = st(bNode, predicate, subject, subject.doc())
        await updater.update([], [st1])
        // expect(updater.anonymize).to.not.have.been.called;
        expect(getPatchCall().lastArg.body).to.equal(`
@prefix solid: <http://www.w3.org/ns/solid/terms#>.
@prefix ex: <http://www.example.org/terms#>.

_:patch

      solid:inserts {
        _:subj <https://pod.example/test/foo#predicate> <https://pod.example/test/foo#subject> .
      };   a solid:InsertDeletePatch .
`)
    });


    it('Constructs n3patch document correctly', async () => {

        updater.store.add(st(namedNode("ex:s1"), namedNode("ex:p1"), namedNode("ex:o1"), subject.doc()));

        await updater.update(
            [st(namedNode("ex:s1"), namedNode("ex:p1"), namedNode("ex:o1"), subject.doc())],
            [st(namedNode("ex:s2"), namedNode("ex:p2"), namedNode("ex:o2"), subject.doc())]
        )
        expect(getPatchCall().lastArg.body).to.equal(`
@prefix solid: <http://www.w3.org/ns/solid/terms#>.
@prefix ex: <http://www.example.org/terms#>.

_:patch

      solid:deletes {
        <ex:s1> <ex:p1> <ex:o1> .
      };
      solid:inserts {
        <ex:s2> <ex:p2> <ex:o2> .
      };   a solid:InsertDeletePatch .
`)
    });

    it('Sets conditions formula to match blank node context', async () => {
        [
            [namedNode("ex:s1"), namedNode("ex:p1"), blankNode("bn1"), subject.doc()],
            [namedNode("ex:s1"), namedNode("ex:p1"), blankNode("bn2"), subject.doc()],
            [blankNode("bn1"), namedNode("ex:p1"), namedNode("ex:o1"), subject.doc()],
            [namedNode("ex:s2"), namedNode("ex:p2"), blankNode("bn3"), subject.doc()],
        ].forEach((st) => {
            updater.store.add(st[0], st[1], st[2], st[3]);
        })

        await updater.update(
            [st(namedNode("ex:s1"), namedNode("ex:p1"), blankNode("bn1"), subject.doc())],
            [st(namedNode("ex:s2"), namedNode("ex:p2"), blankNode("bn3"), subject.doc())]
        )
        expect(getPatchCall().lastArg.body).to.equal(`
@prefix solid: <http://www.w3.org/ns/solid/terms#>.
@prefix ex: <http://www.example.org/terms#>.

_:patch

      solid:where {
        <ex:s1> <ex:p1> ?bn1 .
        ?bn1 <ex:p1> <ex:o1> .
        <ex:s2> <ex:p2> ?bn3 .
      };
      solid:deletes {
        <ex:s1> <ex:p1> ?bn1 .
      };
      solid:inserts {
        <ex:s2> <ex:p2> ?bn3 .
      };   a solid:InsertDeletePatch .
`)
    });

    function getPatchCall() {
        return fetchMock.getCalls().find(it => it.lastArg.method === 'PATCH');
    }
});