Package org.waveprotocol.wave.model.wave

Examples of org.waveprotocol.wave.model.wave.Blip

448
449
450
451
452
453
454
455
456
457
458
459
460
461
462
    return adapt(newBlip);
  }

  @Override
  public ObservableDocument getDocument(String docId) {
    Blip blip = getBlip(docId);
    if (blip == null) {
      blip = createBlip(docId);
    }
    Document doc = blip.getContent();
    if (!(doc instanceof ObservableDocument)) {
      Preconditions.illegalArgument("Document \"" + docId + "\" is not observable");
    }
    return (ObservableDocument) doc;
  }
View Full Code Here
83
84
85
86
87
88
89
90
91
92
93
  static WaveletBasedConversationThread create(ObservableManifestThread manifestThread,
      WaveletBasedConversationBlip parentBlip, WaveletBasedConversation.ComponentHelper helper) {
    WaveletBasedConversationThread thread = new WaveletBasedConversationThread(manifestThread,
        parentBlip, helper);
    for (ObservableManifestBlip manifestBlip : manifestThread.getBlips()) {
      Blip blip = helper.getBlip(manifestBlip.getId());
      if (blip != null) {
        thread.adaptBlip(manifestBlip, blip);
      }
    }
View Full Code Here
164
165
166
167
168
169
170
171
172
173
      Preconditions.illegalArgument(
          "Can't insert blip before blip " + successor + " not from this thread");
    }
    WaveletBasedConversationBlip insertBefore = (WaveletBasedConversationBlip) successor;
    int index = manifestThread.indexOf(insertBefore.getManifestBlip());
    Blip blip = helper.createBlip(null);
    String blipId = blip.getId();
    manifestThread.insertBlip(index, blipId);
    return blips.get(blipId);
  }
View Full Code Here
203
204
205
206
207
208
209
210
211
212
213
  // remote changes. They don't make further changes to the data.
  //

  @Override
  public void onBlipAdded(ObservableManifestBlip manifestBlip) {
    Blip blip = helper.getBlip(manifestBlip.getId());
    if (blip != null) {
      // Note that this means the blip will be ignored if it doesn't exist in
      // the wavelet when the manifest entry is added.
      WaveletBasedConversationBlip convBlip = adaptBlip(manifestBlip, blip);
      triggerOnBlipAdded(convBlip);
View Full Code Here
310
311
312
313
314
315
316
317
318
319
   *
   * @param content  optional content
   * @return new blip.
   */
  private WaveletBasedConversationBlip appendBlipWithContent(DocInitialization content) {
    Blip blip = helper.createBlip(content);
    String blipId = blip.getId();
    manifestThread.appendBlip(blipId);
    return blips.get(blipId);
  }
View Full Code Here
265
266
267
268
269
270
271
272
273
274
275
276
277
   */
  public void testConversationBlipMetadataMatchesWavelet() {
    populate(target);
    ConversationBlip convBlip = target.getRootThread().getFirstBlip();
    Wavelet wavelet = target.getWavelet();
    Blip blip = wavelet.getBlip(convBlip.getId());

    assertEquals(blip.getId(), convBlip.getId());
    assertEquals(blip.getLastModifiedVersion().longValue(), convBlip.getLastModifiedVersion());
    assertEquals(blip.getLastModifiedTime().longValue(), convBlip.getLastModifiedTime());
    assertEquals(blip.getAuthorId(), convBlip.getAuthorId());
    assertEquals(blip.getContributorIds(), convBlip.getContributorIds());
  }
View Full Code Here
72
73
74
75
76
77
78
79
80
    target.init();
  }

  private ConversationBlip mockBlip() {
    ConversationBlip blip = mock(ConversationBlip.class);
    Blip raw = mock(Blip.class);
    when(blip.hackGetRaw()).thenReturn(raw);
    return blip;
  }
View Full Code Here
245
246
247
248
249
250
251
252
253
    return supplement.getThreadState(WaveletBasedConversation.widFor(id), thread.getId());
  }

  @Override
  public boolean isUnread(ConversationBlip blip) {
    Blip raw = blip.hackGetRaw();
    return supplement.isBlipUnread(raw.getWavelet().getId(), raw.getId(), raw
            .getLastModifiedVersion().intValue());
  }
View Full Code Here
295
296
297
298
299
300
301
302
303
304
305
306
307
308
    // Because we use the current wavelet version to mark a blip as read, and
    // because the wavelet version can change independently of that blip, the
    // mark-blip-as-read action is not idempotent. Therefore, to minimise
    // chatter, we do it only for unread blips.
    if (isUnread(b)) {
      Blip raw = b.hackGetRaw();
      Wavelet wavelet = raw.getWavelet();
      supplement.markBlipAsRead(wavelet.getId(), raw.getId(),
          // It is possible that during a VersionUpdateOperatin, the blip version is updated
          // before the wavelet version is updated, hence the max.
          // TODO(user, zdwang) to remove this once the wave model does correct event boundaries.
          (int) Math.max(raw.getLastModifiedVersion(), wavelet.getVersion()));
    }
  }
View Full Code Here
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
     *
     * @param content initial content for the new blip, or {@code null} for
     *        default content
     */
    Blip createBlip(DocInitialization content) {
      Blip blip = wavelet.createBlip(idGenerator.newBlipId());
      if (content != null) {
        blip.getContent().hackConsume(Nindo.fromDocOp(content, false));
      } else {
        Document doc = blip.getContent();
        doc.insertXml(Point.<Doc.N> end(doc.getDocumentElement()),
            Blips.INITIAL_CONTENT);
      }
      return blip;
    }
View Full Code Here
TOP

Related Classes of org.waveprotocol.wave.model.wave.Blip

  • org.waveprotocol.wave.client.wave.LocalSupplementedWaveImplTest
  • org.waveprotocol.wave.model.conversation.WaveletBasedConversation$ComponentHelper
  • org.waveprotocol.wave.model.conversation.WaveletBasedConversationTest
  • org.waveprotocol.wave.model.conversation.WaveletBasedConversationThread
  • org.waveprotocol.wave.model.supplement.SupplementedWaveImpl
  • org.waveprotocol.wave.model.wave.opbased.OpBasedWavelet
    • 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.