Examples of ProtocolWaveletOperation

com.google.walkaround.proto.ProtocolWaveletOperation
org.waveprotocol.wave.federation.Proto.ProtocolWaveletOperation
org.waveprotocol.wave.federation.ProtocolWaveletOperation
Model interface for ProtocolWaveletOperation. Generated from org/waveprotocol/wave/federation/federation.protodevel. Do not edit.

Examples of com.google.walkaround.proto.ProtocolWaveletOperation

  public void setDocFactory(DocumentFactory<?> docFactory) {
    this.docFactory = docFactory;
  }


  public String serializeOperation(WaveletOperation op) {
    ProtocolWaveletOperation opMessage = OperationSerializer.createMessage(op);
    return serializer.serializeOp(opMessage);
  }

View Full Code Here

Examples of com.google.walkaround.proto.ProtocolWaveletOperation

      documentDiffMap.put(documentId, docDiff);
    }


    long version = intermediateVersion;
    for (String mutation : tailMutations) {
      ProtocolWaveletOperation op = serializer.deserializeDelta(mutation).getOperation();


      if (op.hasMutateDocument()) {
        MutateDocument mutateDocument = op.getMutateDocument();
        String documentId = mutateDocument.getDocumentId();


        DocDiff docDiff = documentDiffMap.get(documentId);
        if (docDiff == null) {
          docDiff = new DocDiff(lastReadVersions.get(documentId, 0L));

View Full Code Here

Examples of org.waveprotocol.wave.federation.Proto.ProtocolWaveletOperation

    List<WaveletOperation> ops = Lists.newArrayListWithCapacity(count);
    if (count > 1) {
      WaveletOperationContext context =
          new WaveletOperationContext(author, applicationTimestamp, 1);
      for (int i = 0; i < count - 1; i++) {
        ProtocolWaveletOperation op = delta.getOperation(i);
        ops.add(deserialize(op, context));
      }
    }
    WaveletOperationContext context =
        new WaveletOperationContext(author, applicationTimestamp, 1, resultingVersion);

View Full Code Here

Examples of org.waveprotocol.wave.federation.Proto.ProtocolWaveletOperation

    if (waveDomain != null) {
      ProtocolWaveletDelta.Builder newDelta = ProtocolWaveletDelta.newBuilder(delta);
      ParticipantId author = convertParticipantId(delta.getAuthor(), waveDomain);
      newDelta.setAuthor(author.getAddress());
      for (int i = 0; i < delta.getOperationCount(); i++) {
        ProtocolWaveletOperation op = delta.getOperation(i);
        ProtocolWaveletOperation.Builder newOp = ProtocolWaveletOperation.newBuilder(op);
        if (op.hasAddParticipant()) {
          convertAddParticipantOperation(newOp, op, waveDomain);
        } else if (op.hasRemoveParticipant()) {
          convertRemoveParticipantOperation(newOp, op, waveDomain);
        }
        // TODO(user) release convert for other operations.
        newDelta.setOperation(i, newOp);
      }

View Full Code Here

Examples of org.waveprotocol.wave.federation.Proto.ProtocolWaveletOperation

   * Extract attachment ids from operations.
   */
  public static Set<AttachmentId> getAttachemntIds(ProtocolWaveletDelta delta) {
    Set<AttachmentId> ids = new HashSet<AttachmentId>();
    for (int i=0; i < delta.getOperationCount(); i++) {
      ProtocolWaveletOperation op = delta.getOperation(i);
      if (op.hasMutateDocument()) {
        MutateDocument doc = op.getMutateDocument();
        for (int c = 0; c < doc.getDocumentOperation().getComponentCount(); c++) {
          Component comp = doc.getDocumentOperation().getComponent(c);
          ElementStart start = comp.getElementStart();
          if (ImageConstants.TAGNAME.equals(start.getType())) {
            for (int a=0; a < start.getAttributeCount(); a++) {

View Full Code Here

Examples of org.waveprotocol.wave.federation.Proto.ProtocolWaveletOperation

      }
      author = creator;
    }
    newDelta.setAuthor(author.getAddress());
    for (int i = 0; i < delta.getOperationCount(); i++) {
      ProtocolWaveletOperation op = delta.getOperation(i);
      ProtocolWaveletOperation.Builder newOp = ProtocolWaveletOperation.newBuilder(op);
      if (op.hasAddParticipant()) {
        initAddParticipantOperation(newOp, op, domain, participants);
        if (creator == null && newOp.hasAddParticipant()) {
          creator = ParticipantId.of(newOp.getAddParticipant());
        }
      } else if (op.hasRemoveParticipant()) {
        initRemoveParticipantOperation(newOp, op, domain, participants);
      }
      // TODO (Andrew Kaplanov) import attachments
      newDelta.setOperation(i, newOp);
    }

View Full Code Here

Examples of org.waveprotocol.wave.federation.Proto.ProtocolWaveletOperation

    List<WaveletOperation> ops = Lists.newArrayListWithCapacity(count);
    if (count > 1) {
      WaveletOperationContext context =
          new WaveletOperationContext(author, applicationTimestamp, 1);
      for (int i = 0; i < count - 1; i++) {
        ProtocolWaveletOperation op = delta.getOperation(i);
        ops.add(deserialize(op, context));
      }
    }
    WaveletOperationContext context =
        new WaveletOperationContext(author, applicationTimestamp, 1, resultingVersion);

View Full Code Here

Examples of org.waveprotocol.wave.federation.ProtocolWaveletOperation

   *
   * @param waveletOp wavelet operation to serialize
   * @return serialized protocol buffer wavelet operation
   */
  public static ProtocolWaveletOperation serialize(WaveletOperation waveletOp) {
    ProtocolWaveletOperation protobufOp = ProtocolWaveletOperationJsoImpl.create();


    if (waveletOp instanceof NoOp) {
      protobufOp.setNoOp(true);
    } else if (waveletOp instanceof AddParticipant) {
      protobufOp.setAddParticipant(((AddParticipant) waveletOp).getParticipantId().getAddress());
    } else if (waveletOp instanceof RemoveParticipant) {
      protobufOp.setRemoveParticipant(((RemoveParticipant) waveletOp).getParticipantId()
          .getAddress());
    } else if (waveletOp instanceof WaveletBlipOperation) {
      ProtocolWaveletOperation.MutateDocument mutation =
          ProtocolWaveletOperationJsoImpl.MutateDocumentJsoImpl.create();
      mutation.setDocumentId(((WaveletBlipOperation) waveletOp).getBlipId());
      mutation.setDocumentOperation(serialize(((WaveletBlipOperation) waveletOp).getBlipOp()));
      protobufOp.setMutateDocument(mutation);
    } else {
      throw new IllegalArgumentException("Unsupported operation type: " + waveletOp);
    }


    return protobufOp;

View Full Code Here

Examples of org.waveprotocol.wave.federation.ProtocolWaveletOperation

   *
   * @param waveletOp wavelet operation to serialize
   * @return serialized protocol buffer wavelet operation
   */
  public static ProtocolWaveletOperation serialize(WaveletOperation waveletOp) {
    ProtocolWaveletOperation protobufOp = ProtocolWaveletOperationJsoImpl.create();


    if (waveletOp instanceof NoOp) {
      protobufOp.setNoOp(true);
    } else if (waveletOp instanceof AddParticipant) {
      protobufOp.setAddParticipant(((AddParticipant) waveletOp).getParticipantId().getAddress());
    } else if (waveletOp instanceof RemoveParticipant) {
      protobufOp.setRemoveParticipant(((RemoveParticipant) waveletOp).getParticipantId()
          .getAddress());
    } else if (waveletOp instanceof WaveletBlipOperation) {
      ProtocolWaveletOperation.MutateDocument mutation =
          ProtocolWaveletOperationJsoImpl.MutateDocumentJsoImpl.create();
      mutation.setDocumentId(((WaveletBlipOperation) waveletOp).getBlipId());
      mutation.setDocumentOperation(serialize(((WaveletBlipOperation) waveletOp).getBlipOp()));
      protobufOp.setMutateDocument(mutation);
    } else {
      throw new IllegalArgumentException("Unsupported operation type: " + waveletOp);
    }


    return protobufOp;

View Full Code Here

TOP

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.