Package org.waveprotocol.wave.model.document.operation

Examples of org.waveprotocol.wave.model.document.operation.DocOp

136
137
138
139
140
141
142
143
144
145
146
      Event e = randomEvent();
      out.println("\n" + iter + " " + e + " ========");
      eventCounts.put(e, (eventCounts.containsKey(e) ? eventCounts.get(e) : 0) + 1);
      switch (e) {
      case CLIENT_OP:
        DocOp op = randomOp(client);
        q.clientOp(op);
        break;
      case CLIENT_SEND:
        if (!q.hasUnacknowledgedClientOps() && q.hasQueuedClientOps()) {
          server.sendToServer(q.revision(), q.pushQueuedOpsToUnacked());
View Full Code Here
248
249
250
251
252
253
254
255
256
    throw new AssertionError("Bug");
  }

  private DocOp randomOp(Doc doc) throws OperationException {
    DocOp op = RandomDocOpGenerator.generate(r, p, doc.autoDoc);
    doc.consume(op);
    return op;
  }
View Full Code Here
255
256
257
258
259
260
261
262
263
264
265
  public StringMap<DocOp> deserializeDocumentsDiffs(WaveletDiffSnapshot diffSnapshot)
      throws MessageException {
    StringMap<DocOp> docOps = CollectionUtils.createStringMap();
    try {
      for (DocumentDiffSnapshot docDiff : diffSnapshot.getDocument()) {
        DocOp op;
        if (docDiff.getDiff() == null) {
          op = null;
        } else {
          op = OperationFactory.createDocumentOperation(docDiff.getDiff());
        }
View Full Code Here
330
331
332
333
334
335
336
337
338
339
340
      Preconditions.checkArgument(lastReadVersion >= intermediateVersion
          || lastReadVersion == 0 || lastReadVersion >= document.getLastModifiedVersion(),
          "intermediate wavelet %s is newer (@%s) than last read version %s of doc %s",
          waveletId, intermediateVersion, lastReadVersion, documentId);

      DocOp state = document.getContent().asOperation();
      docDiff.addOperation(documentId, 0, state);

      documentDiffMap.put(documentId, docDiff);
    }
View Full Code Here
384
385
386
387
388
389
390
391
392
393
394
          docDiff.addAllAddedContributor(Collections.<String> emptyList());
          docDiff.addAllRemovedContributor(Collections.<String> emptyList());
          docDiff.setLastModifiedVersion(document.getLastModifiedVersion());
          docDiff.setLastModifiedTime(document.getLastModifiedTime());
          docDiff.setState(OperationSerializer.createMutationOp(diffState.getState()));
          DocOp diffOp = diffState.getDiff();
          if (diffOp != null) {
            docDiff.setDiff(OperationSerializer.createMutationOp(diffOp));
          }
          result.add(docDiff);
        }
View Full Code Here
96
97
98
99
100
101
102
103
    /**
     * @return the state. never null.
     */
    DocOp getState() {
      DocOp op = state.composeAll();
      return op != null ? op : EMPTY_OP;
    }
View Full Code Here
165
166
167
168
169
170
171
172
173
174
175
   * @return The created operation.
   */
  private static DocOp createDocumentOperation(
      final DocOpMessageProvider input, boolean checkWellFormed) throws InvalidInputException {

    DocOp value = new MessageWrapperDocOp(input, checkWellFormed);

    if (checkWellFormed) {
      try {
        if (!DocOpValidator.isWellFormed(null, value)) {
          // Check again, collecting violations this time.
View Full Code Here
94
95
96
97
98
99
100
101
102
103
104
                DocumentHistoryConverter docConverter = docConverters.get(documentId);
                if (docConverter == null) {
                  docConverter = new DocumentHistoryConverter(documentId, nindoConverter);
                  docConverters.put(documentId, docConverter);
                }
                DocOp converted;
                try {
                  converted = docConverter.convertAndApply(blipOp.getContentOp());
                } catch (OperationException e) {
                  throw new InvalidInputException("OperationException converting " + waveletOp, e);
                }
View Full Code Here
73
74
75
76
77
78
79
80
81
82
83
    this.participants = new ArrayList<ParticipantId>();
    this.documents = new HashMap<String, DocOp>();
  }

  private DocOp getOrCreateDocument(String documentId) {
    DocOp doc = documents.get(documentId);
    if (doc == null) {
      doc = EMPTY_DOC_OP;
      documents.put(documentId, doc);
    }
    return doc;
View Full Code Here
109
110
111
112
113
114
115
116
117
118
119
  }

  @Override
  public boolean modifyDocument(String documentId, DocOp operation)
      throws OperationException {
    DocOp newDoc = Composer.compose(getOrCreateDocument(documentId), operation);
    if (OpComparators.SYNTACTIC_IDENTITY.equal(newDoc, EMPTY_DOC_OP)) {
      documents.remove(documentId);
    } else {
      documents.put(documentId, newDoc);
    }
View Full Code Here
TOP

Related Classes of org.waveprotocol.wave.model.document.operation.DocOp

  • com.google.walkaround.slob.client.ChannelTestUtil$FakeServer
  • com.google.walkaround.slob.client.GenericOperationChannelTest
  • com.google.walkaround.slob.client.TransformQueueRandomTest
  • com.google.walkaround.wave.server.googleimport.conversion.WaveletHistoryConverter
  • com.google.walkaround.wave.shared.OperationFactory
  • com.google.walkaround.wave.shared.OperationSerializer$Visitor
  • com.google.walkaround.wave.shared.WaveSerializer
  • com.google.walkaround.wave.shared.WaveSerializer$DocDiff
  • org.waveprotocol.box.common.Snippets
  • org.waveprotocol.box.server.common.CoreWaveletOperationSerializer
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.