jaxoncreed
2 years ago
parent
b941385a6e
commit
64ea2070fd
@ -1,8 +1,147 @@ |
||||
import { LdoTransactionDataset } from "@ldo/ldo"; |
||||
import type { ISolidLdoDataset } from "./types"; |
||||
import type { ResourceGetterOptions } from "./ResourceStore"; |
||||
import type { Container } from "./resource/Container"; |
||||
import type { Leaf } from "./resource/Leaf"; |
||||
import { |
||||
isContainerUri, |
||||
type ContainerUri, |
||||
type LeafUri, |
||||
} from "./util/uriTypes"; |
||||
import type { SolidLdoDatasetContext } from "./SolidLdoDatasetContext"; |
||||
import type { DatasetFactory, Quad } from "@rdfjs/types"; |
||||
import type { ITransactionDatasetFactory } from "@ldo/subscribable-dataset"; |
||||
import type { SolidLdoDataset } from "./SolidLdoDataset"; |
||||
import type { AggregateSuccess } from "./requester/results/success/SuccessResult"; |
||||
import type { ResourceResult } from "./resource/resourceResult/ResourceResult"; |
||||
import type { |
||||
UpdateDefaultGraphSuccess, |
||||
UpdateSuccess, |
||||
} from "./requester/results/success/UpdateSuccess"; |
||||
import { AggregateError } from "./requester/results/error/ErrorResult"; |
||||
import type { |
||||
UpdateResult, |
||||
UpdateResultError, |
||||
} from "./requester/requests/updateDataResource"; |
||||
import { InvalidUriError } from "./requester/results/error/InvalidUriError"; |
||||
import type { DatasetChanges, GraphNode } from "@ldo/rdf-utils"; |
||||
import { splitChangesByGraph } from "./util/splitChangesByGraph"; |
||||
|
||||
export class SolidLdoTransactionDataset |
||||
extends LdoTransactionDataset |
||||
implements ISolidLdoDataset { |
||||
|
||||
implements ISolidLdoDataset |
||||
{ |
||||
/** |
||||
* @internal |
||||
*/ |
||||
public context: SolidLdoDatasetContext; |
||||
|
||||
/** |
||||
* @param context - SolidLdoDatasetContext |
||||
* @param datasetFactory - An optional dataset factory |
||||
* @param transactionDatasetFactory - A factory for creating transaction datasets |
||||
* @param initialDataset - A set of triples to initialize this dataset |
||||
*/ |
||||
constructor( |
||||
parentDataset: SolidLdoDataset, |
||||
context: SolidLdoDatasetContext, |
||||
datasetFactory: DatasetFactory, |
||||
transactionDatasetFactory: ITransactionDatasetFactory<Quad>, |
||||
) { |
||||
super(parentDataset, datasetFactory, transactionDatasetFactory); |
||||
this.context = context; |
||||
} |
||||
|
||||
/** |
||||
* Retireves a representation (either a LeafResource or a ContainerResource) |
||||
* of a Solid Resource at the given URI. This resource represents the |
||||
* current state of the resource: whether it is currently fetched or in the |
||||
* process of fetching as well as some information about it. |
||||
* |
||||
* @param uri - the URI of the resource |
||||
* @param options - Special options for getting the resource |
||||
* |
||||
* @returns a Leaf or Container Resource |
||||
* |
||||
* @example |
||||
* ```typescript
|
||||
* const profileDocument = solidLdoDataset |
||||
* .getResource("https://example.com/profile"); |
||||
* ``` |
||||
*/ |
||||
getResource(uri: ContainerUri, options?: ResourceGetterOptions): Container; |
||||
getResource(uri: LeafUri, options?: ResourceGetterOptions): Leaf; |
||||
getResource(uri: string, options?: ResourceGetterOptions): Leaf | Container; |
||||
getResource(uri: string, options?: ResourceGetterOptions): Leaf | Container { |
||||
return this.context.resourceStore.get(uri, options); |
||||
} |
||||
|
||||
async commitToPod(): Promise< |
||||
| AggregateSuccess< |
||||
ResourceResult<UpdateSuccess | UpdateDefaultGraphSuccess, Leaf> |
||||
> |
||||
| AggregateError<UpdateResultError | InvalidUriError> |
||||
> { |
||||
const changes = this.getChanges(); |
||||
const changesByGraph = splitChangesByGraph(changes); |
||||
|
||||
// Iterate through all changes by graph in
|
||||
const results: [ |
||||
GraphNode, |
||||
DatasetChanges<Quad>, |
||||
UpdateResult | InvalidUriError | UpdateDefaultGraphSuccess, |
||||
][] = await Promise.all( |
||||
Array.from(changesByGraph.entries()).map( |
||||
async ([graph, datasetChanges]) => { |
||||
if (graph.termType === "DefaultGraph") { |
||||
// Undefined means that this is the default graph
|
||||
this.bulk(datasetChanges); |
||||
return [ |
||||
graph, |
||||
datasetChanges, |
||||
{ |
||||
type: "updateDefaultGraphSuccess", |
||||
isError: false, |
||||
} as UpdateDefaultGraphSuccess, |
||||
]; |
||||
} |
||||
if (isContainerUri(graph.value)) { |
||||
return [ |
||||
graph, |
||||
datasetChanges, |
||||
new InvalidUriError( |
||||
graph.value, |
||||
`Container URIs are not allowed for custom data.`, |
||||
), |
||||
]; |
||||
} |
||||
const resource = this.getResource(graph.value as LeafUri); |
||||
const updateResult = await resource.update(datasetChanges); |
||||
return [graph, datasetChanges, updateResult]; |
||||
}, |
||||
), |
||||
); |
||||
|
||||
// If one has errored, return error
|
||||
const errors = results.filter((result) => result[2].isError); |
||||
|
||||
if (errors.length > 0) { |
||||
return new AggregateError( |
||||
errors.map( |
||||
(result) => result[2] as UpdateResultError | InvalidUriError, |
||||
), |
||||
); |
||||
} |
||||
return { |
||||
isError: false, |
||||
type: "aggregateSuccess", |
||||
results: results |
||||
.map((result) => result[2]) |
||||
.filter( |
||||
(result): result is ResourceResult<UpdateSuccess, Leaf> => |
||||
result.type === "updateSuccess" || |
||||
result.type === "updateDefaultGraphSuccess", |
||||
), |
||||
}; |
||||
} |
||||
} |
||||
|
||||
Loading…
Reference in new issue