Package org.waveprotocol.wave.model.wave

Examples of org.waveprotocol.wave.model.wave.ParticipantId

196
197
198
199
200
201
202
203
204
205
206
    websocket = new WaveWebSocketClient(websocketNotAvailable(), getWebSocketBaseUrl());
    websocket.connect();

    if (Session.get().isLoggedIn()) {
      loggedInUser = new ParticipantId(Session.get().getAddress());
      idGenerator = ClientIdGenerator.create();
      loginToServer();
    }

    setupUi();
View Full Code Here
122
123
124
125
126
127
128
129
130
131
132
   */
  @Timed
  @Override
  @VisibleForTesting
  protected void doGet(HttpServletRequest req, HttpServletResponse response) throws IOException {
    ParticipantId user = sessionManager.getLoggedInUser(req.getSession(false));
    if (user == null) {
      response.setStatus(HttpServletResponse.SC_FORBIDDEN);
      return;
    }
    SearchRequest searchRequest = parseSearchRequest(req, response);
View Full Code Here
82
83
84
85
86
87
88
89
90
91
92
   * Create an http response to the fetch query. Main entrypoint for this class.
   */
  @Override
  @VisibleForTesting
  protected void doGet(HttpServletRequest req, HttpServletResponse response) throws IOException {
    ParticipantId user = sessionManager.getLoggedInUser(req.getSession(false));

    // This path will look like "/example.com/w+abc123/foo.com/conv+root
    // Strip off the leading '/'.
    String urlPath = req.getPathInfo().substring(1);

View Full Code Here
262
263
264
265
266
267
268
269
270
271
272
          token = token + "@" + localDomain;
        } else if (token.equals("@")) {
          // "@" is a shortcut for the shared domain participant.
          token = "@" + localDomain;
        }
        ParticipantId otherUser = ParticipantId.of(token);
        participants.add(otherUser);
      }
    } else {
      participants = Collections.emptyList();
    }
View Full Code Here
115
116
117
118
119
120
121
122
123
124
125
      }
    } else {
      waveletName = AttachmentUtil.waveRef2WaveletName(metadata.getWaveRef());
    }

    ParticipantId user = sessionManager.getLoggedInUser(request.getSession(false));
    boolean isAuthorized = false;
    try {
      isAuthorized = waveletProvider.checkAccessPermission(waveletName, user);
    } catch (WaveServerException e) {
      LOG.warning("Problem while authorizing user: " + user + " for wavelet: " + waveletName, e);
View Full Code Here
213
214
215
216
217
218
219
220
221
222
223
          response.sendError(HttpServletResponse.SC_BAD_REQUEST, "No wave reference in request.");
          return;
        }

        WaveletName waveletName = AttachmentUtil.waveRef2WaveletName(waveRefStr);
        ParticipantId user = sessionManager.getLoggedInUser(request.getSession(false));
        boolean isAuthorized = waveletProvider.checkAccessPermission(waveletName, user);
        if (!isAuthorized) {
          response.sendError(HttpServletResponse.SC_FORBIDDEN);
          return;
        }
View Full Code Here
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
        if (op instanceof AddParticipant) {
          if(LOG.isInfoLoggable()) {
            LOG.info("Update contains AddParticipant for " + ((AddParticipant)op).getParticipantId());
          }

          ParticipantId user = ((AddParticipant) op).getParticipantId();
          // Check first if we need to update views for this user.
          for (Listener listener : listeners) {
            listener.onParticipantAdded(waveletName, user);
          }
        } else if (op instanceof RemoveParticipant) {
          ParticipantId user = ((RemoveParticipant) op).getParticipantId();
          for (Listener listener : listeners) {
            listener.onParticipantRemoved(waveletName, user);
          }
        }
      }
View Full Code Here
64
65
66
67
68
69
70
71
72
73
74
  }

  @Override
  public AccountData getLoggedInAccount(HttpSession session) {
    // Consider caching the account data in the session object.
    ParticipantId user = getLoggedInUser(session);
    if (user != null) {
      try {
        return accountStore.getAccount(user);
      } catch (PersistenceException e) {
        LOG.warning("Failed to retrieve account data for " + user, e);
View Full Code Here
223
224
225
226
227
228
229
230
    protected abstract void sendMessage(int sequenceNo, Message message);

    private ParticipantId authenticate(String token) {
      HttpSession session = provider.sessionManager.getSessionFromToken(token);
      ParticipantId user = provider.sessionManager.getLoggedInUser(session);
      return user;
    }
View Full Code Here
250
251
252
253
254
255
256
257
258
259
260
        // (in which case loggedInUser must match the authenticated user, and
        // this message has no
        // effect).

        ProtocolAuthenticate authMessage = (ProtocolAuthenticate) message;
        ParticipantId authenticatedAs = authenticate(authMessage.getToken());

        Preconditions.checkArgument(authenticatedAs != null, "Auth token invalid");
        Preconditions.checkState(loggedInUser == null || loggedInUser.equals(authenticatedAs),
            "Session already authenticated as a different user");
View Full Code Here
TOP

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

  • com.google.walkaround.wave.shared.WaveSerializer
  • org.waveprotocol.box.expimp.DomainConverter
  • org.waveprotocol.box.server.authentication.AccountStoreLoginModule
  • org.waveprotocol.box.server.authentication.SessionManagerImpl
  • org.waveprotocol.box.server.common.CoreWaveletOperationSerializer
  • org.waveprotocol.box.server.common.SnapshotSerializer
  • org.waveprotocol.box.server.common.WaveletOperationSerializerTest
  • org.waveprotocol.box.server.frontend.ClientFrontendImpl
  • org.waveprotocol.box.server.frontend.WaveClientRpcImpl
  • org.waveprotocol.box.server.persistence.protos.ProtoAccountDataSerializer
    • 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.