Package org.eurekastreams.commons.actions.context

Examples of org.eurekastreams.commons.actions.context.Principal

79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
        DeleteFeedSubscriptionRequest request = (DeleteFeedSubscriptionRequest) inActionContext.getParams();
        Serializable[] paramsForAuthorizor = new Serializable[1];
        paramsForAuthorizor[0] = request.getEntityId();

        HashMap<String, Serializable> values = new HashMap<String, Serializable>();
        Principal principal = inActionContext.getPrincipal();
        values.put("EUREKA:USER", principal.getAccountId());
        values.put("EUREKA:GROUP", request.getEntityId());

        List<FeedSubscriber> feedSubs =
                getFeedSubsMapper.execute(new GetFeedSubscriberRequest(0L, getEntityId.getEntityId(values), type,
                        principal.getId()));

        boolean found = false;

        for (FeedSubscriber feedSub : feedSubs)
        {
View Full Code Here
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
     *            the action context
     */
    public void authorize(final PrincipalActionContext inActionContext)
    {
        ActivityDTO activity = null;
        final Principal principal = inActionContext.getPrincipal();
        try
        {
            long activityId = activityIdFromParamsTransformer.transform(inActionContext.getParams());
            activity = getActivityDAO.execute(activityId);
        }
        catch (Exception ex)
        {
            logger.error("Error occurred retrieving the activity dto params.", ex);
            throw new AuthorizationException(
                    "This action could not authorize the request due to failure retrieving parameters.", ex);
        }

        if (!activityAuthorizer.authorize(principal.getId(), activity, type))
        {
            throw new AuthorizationException("Current user does not have permissions to "
                    + type.toString().toLowerCase() + " activity.");
        }
    }
View Full Code Here
110
111
112
113
114
115
116
117
118
119
120
121
                allowing(person).getEntityId();
                will(returnValue(entityId));
            }
        });

        Principal result = sut.execute(openSocialId);
        assertEquals(accountId, result.getAccountId());
        assertEquals(openSocialId, result.getOpenSocialId());
        assertEquals(entityId, result.getId().longValue());

        context.assertIsSatisfied();
    }
View Full Code Here
144
145
146
147
148
149
150
151
152
153
154
155
                allowing(person).getEntityId();
                will(returnValue(entityId));
            }
        });

        Principal result = sut.execute(openSocialId);
        assertEquals(accountId, result.getAccountId());
        assertEquals(openSocialId, result.getOpenSocialId());
        assertEquals(entityId, result.getId().longValue());

        context.assertIsSatisfied();
    }
View Full Code Here
169
170
171
172
173
174
175
176
177
                oneOf(getPersonModelViewByAccountIdMapper).execute(openSocialId);
                will(returnValue(null));
            }
        });

        Principal result = sut.execute(openSocialId);

        context.assertIsSatisfied();
    }
View Full Code Here
188
189
190
191
192
193
194
195
196
                allowing(personMapper).fetchUniqueResult(openSocialId);
                will(throwException(new Exception()));
            }
        });

        Principal result = sut.execute(openSocialId);

        context.assertIsSatisfied();
    }
View Full Code Here
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
    {
        log.debug("Entering createActivity data with userId " + userId.getUserId(token) + ", appId " + appId + ", "
                + fields.size() + ", AcivityId " + activity.getId() + ", token appId " + token.getAppId());
        try
        {
            Principal currentUserPrincipal = openSocialPrincipalDao.execute(userId.getUserId(token));

            // Create the actor.
            StreamEntityDTO actorEntity = new StreamEntityDTO();
            actorEntity.setUniqueIdentifier(currentUserPrincipal.getOpenSocialId());
            actorEntity.setType(EntityType.PERSON);

            // Create the destination stream.
            StreamEntityDTO destStream = new StreamEntityDTO();
            destStream.setUniqueIdentifier(currentUserPrincipal.getAccountId());
            destStream.setType(EntityType.PERSON);

            // Create the activitydto object.
            ActivityDTO currentActivity = new ActivityDTO();
            currentActivity.setActor(actorEntity);
View Full Code Here
261
262
263
264
265
266
267
268
269
270
271
            final Set<String> activityIds, final SecurityToken token)
    {
        log.debug("Entering deleteActivities data with userId" + userId.getUserId(token) + ", appId " + appId + ", "
                + activityIds.size() + ", token appId " + token.getAppId());

        Principal currentUserPrincipal = openSocialPrincipalDao.execute(userId.getUserId(token));

        try
        {
            // convert set of string to list of longs to call action with.
            ArrayList<Long> params = new ArrayList<Long>(activityIds.size());
View Full Code Here
88
89
90
91
92
93
94
95
96
97
98
    /**
     * Check the DestinationStream type and perform the appropriate authorization strategy. {@inheritDoc}.
     */
    public void authorize(final ServiceActionContext inActionContext)
    {
        Principal currentPrincipal = inActionContext.getPrincipal();
        PostActivityRequest currentRequest = (PostActivityRequest) inActionContext.getParams();

        switch (currentRequest.getActivityDTO().getDestinationStream().getType())
        {
        case PERSON:
View Full Code Here
267
268
269
270
271
272
273
274
275
276
277
    {
        log.debug("Attempting to retrieve principal");

        for (Transformer<Request, Principal> extractor : principalExtractors)
        {
            Principal result = extractor.transform(inRequest);
            if (result != null)
            {
                return result;
            }
        }
View Full Code Here
TOP

Related Classes of org.eurekastreams.commons.actions.context.Principal

  • org.eurekastreams.commons.actions.InlineActionExecutor
  • org.eurekastreams.commons.actions.InlineExecutionStrategyExecutor
  • org.eurekastreams.server.action.authorization.feed.DeleteFeedSubscriberAuthorizationStrategy
  • org.eurekastreams.server.action.authorization.stream.ActivityAuthorizationStrategy
  • org.eurekastreams.server.action.authorization.stream.PostActivityAuthorizationStrategy
  • org.eurekastreams.server.action.authorization.stream.PostActivityAuthorizationStrategyTest
  • org.eurekastreams.server.action.execution.feed.AddFeedToEntityExecution
  • org.eurekastreams.server.action.execution.feed.GetPluginsAndSubscriptionsForTabExecution
  • org.eurekastreams.server.action.execution.GetStreamDiscoverListsDTOExecutionTest
  • org.eurekastreams.server.action.execution.opensocial.GetUserActivitiesExecutionTest
    • 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.