Skip to content
This repository has been archived by the owner on Apr 17, 2023. It is now read-only.

Remove Queue Update Processor (Fixes #862) #970

Merged
merged 2 commits into from
Nov 30, 2020
Merged
Show file tree
Hide file tree
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Next Next commit
chore: remove update queue processor
  • Loading branch information
kingsleyzissou committed Nov 30, 2020
commit f057ec610654f5e431417afcdc2c74c1c1399b3f
Original file line number Diff line number Diff line change
Expand Up @@ -12,7 +12,6 @@ import { GlobalReplicationConfig, MutationsConfig } from "../api/ReplicationConf
import { buildGraphQLCRUDMutations } from "./buildGraphQLCRUDMutations";
import invariant from "tiny-invariant";
import { getFirstOperationData } from "../utils/getFirstOperationData";
import { QueueUpdateProcessor } from "./QueueUpdateProcessor";

const logger = createLogger("replicator-mutationqueue");

Expand Down Expand Up @@ -300,11 +299,7 @@ export class MutationsReplicationQueue implements ModelChangeReplication {
// TODO handling for ADD works but it really convoluted
const transaction = await this.options.storage.createTransaction();
try {
const queueUpdateProcessor = new QueueUpdateProcessor(
this.modelMap, currentItem, returnedData, transaction);

const items: MutationRequest[] = await this.getStoredMutations();
await queueUpdateProcessor.updateQueue(items);

// persist queue. No need to await here since we will await trx.commit
transaction.saveOrUpdate(
Expand Down

This file was deleted.