Skip to content

Commit

Permalink
feat(sync): delete author in logRemoteOperationSubject
Browse files Browse the repository at this point in the history
  • Loading branch information
cedricenclos committed Nov 21, 2018
1 parent eb9f396 commit 7f0e2d8
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 6 deletions.
6 changes: 3 additions & 3 deletions src/MuteCore.ts
Original file line number Diff line number Diff line change
Expand Up @@ -111,7 +111,7 @@ export class MuteCore extends Disposable {
(v1, v2) => ({ v1, v2 })
)
this.newSub = e.subscribe(({ v1, v2 }) => {
this.logRemoteOperation(muteCoreId, v1.textop, v1.logootsop, v2.clock, v2.author)
this.logRemoteOperation(muteCoreId, v1.textop, v1.logootsop, v2.clock, v1.logootsop.author)
})
}

Expand Down Expand Up @@ -238,7 +238,7 @@ export class MuteCore extends Disposable {
type: 'localInsertion',
siteId: id,
clock: this.sync.getClock,
position: textoperation.offset,
position: textoperation.index,
content: textoperation.content,
length: textoperation.content.length,
logootsOperation: o,
Expand All @@ -251,7 +251,7 @@ export class MuteCore extends Disposable {
type: 'localDeletion',
siteId: id,
clock: this.sync.getClock,
position: textoperation.offset,
position: textoperation.index,
length: textoperation.length,
logootsOperation: o,
context: this.sync.getVector,
Expand Down
3 changes: 0 additions & 3 deletions src/sync/Sync.ts
Original file line number Diff line number Diff line change
Expand Up @@ -30,7 +30,6 @@ export class Sync extends Disposable {
}>
private logsRemoteRichLogootsOperationsSubject: Subject<{
clock: number
author: number
operation: LogootSOperation
}>
private replySyncSubject: Subject<ReplySyncEvent>
Expand Down Expand Up @@ -76,7 +75,6 @@ export class Sync extends Disposable {

get logsRemoteRichLogootsOperations$(): Observable<{
clock: number
author: number
operation: LogootSOperation
}> {
return this.logsRemoteRichLogootsOperationsSubject.asObservable()
Expand Down Expand Up @@ -173,7 +171,6 @@ export class Sync extends Disposable {
logootSOperations.push(logootSOp)
this.logsRemoteRichLogootsOperationsSubject.next({
clock: op.clock,
author: op.id,
operation: op.logootSOp,
})
} else {
Expand Down

0 comments on commit 7f0e2d8

Please sign in to comment.