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

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


   * @param destWavelet the destination wavelet
   * @param docId the id of the document to copy
   */
  public static void copyDocument(Wavelet sourceWavelet, Wavelet destWavelet, String docId) {
    Document document = sourceWavelet.getDocument(docId);
    DocInitialization docInit = document.toInitialization();
    // TODO(user): add a createDocument method to Wavelet so that we can push this ugliness
    // down the stack.
    ObservableDocument destDoc = destWavelet.getDocument(docId);
    destDoc.hackConsume(Nindo.fromDocOp(docInit, false /* don't remove skip */));
  }
View Full Code Here


      if (performValidation) {
        bothOps = Composer.compose(domOp, annotationsOp);
      } else {
        bothOps = Composer.composeUnchecked(domOp, annotationsOp);
      }
      DocInitialization initialisation = DocOpUtil.asInitialization(bothOps);
      assert DocOpValidator.validate(null, schemaConstraints, initialisation).isValid();

      return initialisation;
    } catch (OperationException e) {
      throw new OperationRuntimeException("Bug either in indexed document or the composer", e);
View Full Code Here

        NO_SCHEMA_CONSTRAINTS);
  }

  @Override
  public IndexedDocument<N, E, T> parse(String text) {
    DocInitialization docInitialization;
    try {
      docInitialization = DocOpUtil.docInitializationFromXml(text);
    } catch (XmlParseException e) {
      throw new IllegalArgumentException(e);
    }
View Full Code Here

    long time = 1234567890;

    WaveletData wavelet = WaveletDataUtil.createEmptyWavelet(name, creator,
        HashedVersion.unsigned(0), time);

    DocInitialization content = new DocInitializationBuilder().characters("Hello there").build();
    wavelet.createDocument(
        "b+abc123", creator, Collections.<ParticipantId> emptySet(), content, time, 0);

    return wavelet;
  }
View Full Code Here

    schemas.add(new ConversationSchemas());
    schemas.add(new UserDataSchemas());
  }

  public void testLoadOnDomainlessWaveletIdsDoesNotFail() {
    DocInitialization readOp =
        BasicFactories.observableDocumentProvider().parse(
            "<wavelet i=\"conversation/root\"></wavelet>").toInitialization();
    DocInitialization archiveOp =
        BasicFactories.observableDocumentProvider().parse(
            "<archive i=\"conversation/root\"></archive>").toInitialization();
    DocInitialization seenOp =
        BasicFactories.observableDocumentProvider().parse(
            "<seen i=\"conversation/root\"></seen>").toInitialization();

    FakeWaveView view = BasicFactories.fakeWaveViewBuilder().build();
    Wavelet userData = view.createUserData();
View Full Code Here

    }
    return waveletData;
  }

  private static void deserialize(WaveletDataImpl waveletData, DocumentSnapshot docSnapshot) {
    DocInitialization content =
        DocOpUtil.asInitialization(WaveletOperationSerializer.deserialize(docSnapshot
            .getDocumentOperation()));
    String docId = docSnapshot.getDocumentId();
    ParticipantId author = ParticipantId.ofUnsafe(docSnapshot.getAuthor());
    List<ParticipantId> contributors = Lists.newArrayList();
View Full Code Here

  }

  private static void addDocumentSnapshotToWavelet(
      DocumentSnapshot snapshot, WaveletData container) throws InvalidParticipantAddress {
    DocOp op = WaveletOperationSerializer.deserialize(snapshot.getDocumentOperation());
    DocInitialization docInit = DocOpUtil.asInitialization(op);

    Collection<ParticipantId> contributors = CollectionUtils.newArrayList();
    for (String p : snapshot.getContributor()) {
      contributors.add(ParticipantId.of(p));
    }
View Full Code Here

    final StringBuilder opB = new StringBuilder();
    final StringBuilder indicesB = new StringBuilder();

    final StringBuilder[] builders = { docB, opB, indicesB };

    final DocInitialization exploded = ExplodedDocOp.explode(doc);

    final int numDocComponents = exploded.size();

    final DocOpCursor opStringifier = createConciseStringBuilder(op, opB);

    final DocInitializationBuffer target = new DocInitializationBuffer();
    new Runnable() {
      int index = 0;
      int docItem = 0;

      private void runTarget(int itemCount) {
        indicesB.append(docItem);
        docItem += itemCount;
        while (index < numDocComponents && itemCount > 0) {
          exploded.applyComponent(index, target);
          if (exploded.getType(index) != DocOpComponentType.ANNOTATION_BOUNDARY) {
            itemCount--;
          }
          index++;
        }
      }
View Full Code Here

   * Creates an observable mutable document with some schema, content, and sink.
   */
  public static ObservableDocument createDocument(DocumentSchema schema,
      String initialContent, SilentOperationSink<? super DocOp> sink) {
    Preconditions.checkNotNull(sink, "Sink can't be null");
    DocInitialization init = DocProviders.POJO.parse(initialContent).asOperation();
    ObservablePluggableMutableDocument doc = new ObservablePluggableMutableDocument(schema, init);
    doc.init(sink);
    return doc;
  }
View Full Code Here

  }

  private static void addDocumentSnapshotToWavelet(
      DocumentSnapshot snapshot, WaveletData container) throws InvalidParticipantAddress {
    DocOp op = CoreWaveletOperationSerializer.deserialize(snapshot.getDocumentOperation());
    DocInitialization docInit = DocOpUtil.asInitialization(op);

    Collection<ParticipantId> contributors = CollectionUtils.newArrayList();
    for (String p : snapshot.getContributorList()) {
      contributors.add(getParticipantId(p));
    }
View Full Code Here

TOP

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

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.