| /* |
| * Licensed to the Apache Software Foundation (ASF) under one |
| * or more contributor license agreements. See the NOTICE file |
| * distributed with this work for additional information |
| * regarding copyright ownership. The ASF licenses this file |
| * to you under the Apache License, Version 2.0 (the |
| * "License"); you may not use this file except in compliance |
| * with the License. You may obtain a copy of the License at |
| * |
| * http://www.apache.org/licenses/LICENSE-2.0 |
| * |
| * Unless required by applicable law or agreed to in writing, |
| * software distributed under the License is distributed on an |
| * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY |
| * KIND, either express or implied. See the License for the |
| * specific language governing permissions and limitations |
| * under the License. |
| */ |
| package org.apache.syncope.client.enduser.pages; |
| |
| import java.util.Collections; |
| import java.util.Iterator; |
| import java.util.stream.Collectors; |
| import org.apache.commons.lang3.StringUtils; |
| import org.apache.syncope.client.enduser.SyncopeEnduserSession; |
| import org.apache.syncope.client.enduser.markup.html.form.BpmnProcessesAjaxPanel; |
| import org.apache.syncope.client.enduser.panels.UserRequestDetails; |
| import org.apache.syncope.client.enduser.rest.BpmnProcessRestClient; |
| import org.apache.syncope.client.enduser.rest.UserRequestRestClient; |
| import org.apache.syncope.client.ui.commons.Constants; |
| import org.apache.syncope.client.ui.commons.ajax.form.IndicatorAjaxFormComponentUpdatingBehavior; |
| import org.apache.syncope.client.ui.commons.annotations.ExtPage; |
| import org.apache.syncope.client.ui.commons.wicket.markup.html.bootstrap.tabs.Accordion; |
| import org.apache.syncope.common.lib.to.BpmnProcess; |
| import org.apache.syncope.common.lib.to.UserRequest; |
| import org.apache.wicket.ajax.AjaxRequestTarget; |
| import org.apache.wicket.ajax.markup.html.AjaxLink; |
| import org.apache.wicket.ajax.markup.html.navigation.paging.AjaxPagingNavigator; |
| import org.apache.wicket.extensions.markup.html.repeater.util.SortParam; |
| import org.apache.wicket.extensions.markup.html.tabs.AbstractTab; |
| import org.apache.wicket.extensions.markup.html.tabs.ITab; |
| import org.apache.wicket.markup.html.WebMarkupContainer; |
| import org.apache.wicket.markup.repeater.Item; |
| import org.apache.wicket.markup.repeater.data.DataView; |
| import org.apache.wicket.markup.repeater.data.IDataProvider; |
| import org.apache.wicket.model.IModel; |
| import org.apache.wicket.model.Model; |
| import org.apache.wicket.model.StringResourceModel; |
| import org.apache.wicket.request.mapper.parameter.PageParameters; |
| |
| @ExtPage(label = "User Requests", icon = "fa fa-briefcase", listEntitlement = "") |
| public class Flowable extends BasePage { |
| |
| private static final long serialVersionUID = -8781434495150074529L; |
| |
| private static final String USER_REQUESTS = "page.userRequests"; |
| |
| private final int rowsPerPage = 5; |
| |
| private final Model<String> bpmnProcessModel = new Model<>(); |
| |
| private final WebMarkupContainer container; |
| |
| private final DataView<UserRequest> urDataView; |
| |
| public Flowable(final PageParameters parameters) { |
| super(parameters, USER_REQUESTS); |
| |
| container = new WebMarkupContainer("content"); |
| container.setOutputMarkupId(true); |
| |
| // list of accordions containing request form (if any) and delete button |
| urDataView = new DataView<UserRequest>("userRequests", new URDataProvider(rowsPerPage, "bpmnProcess")) { |
| |
| private static final long serialVersionUID = -5002600396458362774L; |
| |
| @Override |
| protected void populateItem(final Item<UserRequest> item) { |
| final UserRequest userRequest = item.getModelObject(); |
| item.add(new Accordion("userRequestDetails", Collections.<ITab>singletonList(new AbstractTab( |
| new StringResourceModel("user.requests.accordion", container, Model.of(userRequest))) { |
| |
| private static final long serialVersionUID = 1037272333056449378L; |
| |
| @Override |
| public WebMarkupContainer getPanel(final String panelId) { |
| // find the form associated to the current request, if any |
| return new UserRequestDetails( |
| panelId, userRequest, container, notificationPanel, getPageReference()); |
| } |
| }), Model.of(-1)).setOutputMarkupId(true)); |
| } |
| }; |
| |
| urDataView.setItemsPerPage(rowsPerPage); |
| urDataView.setOutputMarkupId(true); |
| container.add(urDataView); |
| container.add(new AjaxPagingNavigator("navigator", urDataView)); |
| |
| AjaxLink<Void> startButton = new AjaxLink<Void>("start") { |
| |
| private static final long serialVersionUID = 3669569969172391336L; |
| |
| @Override |
| public void onClick(final AjaxRequestTarget target) { |
| if (StringUtils.isNotBlank(bpmnProcessModel.getObject())) { |
| try { |
| UserRequestRestClient.startRequest(bpmnProcessModel.getObject(), null); |
| } catch (Exception e) { |
| LOG.error("Unable to start bpmnProcess [{}]", bpmnProcessModel.getObject(), e); |
| SyncopeEnduserSession.get() |
| .error(String.format("Unable to start bpmnProcess [%s]", e.getMessage())); |
| notificationPanel.refresh(target); |
| } |
| target.add(container); |
| } |
| } |
| }; |
| |
| startButton.setEnabled(false); |
| container.add(startButton); |
| |
| // autocomplete select with bpmnProcesses |
| BpmnProcessesAjaxPanel bpmnProcesses = new BpmnProcessesAjaxPanel("bpmnProcesses", "bpmnProcesses", |
| bpmnProcessModel, new IndicatorAjaxFormComponentUpdatingBehavior(Constants.ON_CHANGE) { |
| |
| private static final long serialVersionUID = -1107858522700306810L; |
| |
| @Override |
| protected void onUpdate(final AjaxRequestTarget target) { |
| if (StringUtils.isNotBlank(bpmnProcessModel.getObject())) { |
| startButton.setEnabled(true); |
| } else { |
| startButton.setEnabled(false); |
| } |
| target.add(container); |
| } |
| }); |
| bpmnProcesses.setChoices(BpmnProcessRestClient.getDefinitions().stream() |
| .filter(definition -> !definition.isUserWorkflow()) |
| .map(BpmnProcess::getKey).collect(Collectors.toList())); |
| container.add(bpmnProcesses); |
| |
| contentWrapper.add(container); |
| } |
| |
| public static class URDataProvider implements IDataProvider<UserRequest> { |
| |
| private static final long serialVersionUID = 1169386589403139714L; |
| |
| protected final int paginatorRows; |
| |
| protected final String sortParam; |
| |
| public URDataProvider(final int paginatorRows, final String sortParam) { |
| this.paginatorRows = paginatorRows; |
| this.sortParam = sortParam; |
| } |
| |
| @Override |
| public Iterator<UserRequest> iterator(final long first, final long count) { |
| int page = ((int) first / paginatorRows); |
| return UserRequestRestClient.listRequests((page < 0 ? 0 : page) + 1, |
| paginatorRows, |
| SyncopeEnduserSession.get().getSelfTO().getUsername(), |
| new SortParam<>(sortParam, true)).iterator(); |
| } |
| |
| @Override |
| public long size() { |
| return UserRequestRestClient.countRequests(); |
| } |
| |
| @Override |
| public IModel<UserRequest> model(final UserRequest ur) { |
| return Model.of(ur); |
| } |
| } |
| } |