to create a new Java class BaseApiServiceImpl containing the base structure for all the API implementation classes in the site with helpful methods for persistence, authentication and more.

[computate]

Mission to create a new Java class BaseApiServiceImpl containing the base structure for all the API implementation classes in the site with helpful methods for persistence, authentication and more.

Your mission, should you choose to accept it, is to create a new Java class BaseApiServiceImpl containing the base structure for all the API implementation classes in the site with helpful methods for persistence, authentication and more. .

The day of the operation is October 26th, 2021

You will have 4 hours to complete your mission.

One of the project’s major goals is to establish https://cc.curriki.org as the global authoring and distribution hub and library for openly licensed, next generation, open educational resources (OER+) under the least restrictive Creative Commons license, CC-BY.

You will be joining a team of the boldest

of all Red Hatters for this mission, who will be at your service developing the code and automating the deployment to OpenShift.

• Should you, or any of your force be taken or compromised that day, you must report back as many changes as you have made, and any knowledge of your actions, by pull request or comments on the issue on the board.

How to get started:

Follow the instructions here to setup the project: https://github.com/team19hackathon2021/ActiveLearningStudio-API/tree/master/src

The details of your mission:

• The Java package name will be: org.curriki.api.enus.base
• The Java class name will be: BaseApiServiceImpl
• The path to the Java class will be: /usr/local/src/ActiveLearningStudio-API/src/main/java/org/curriki/api/enus/base/BaseApiServiceImpl.java

package org.curriki.api.enus.base;

import java.util.List;
import java.util.Optional;
import java.util.stream.Collectors;
import org.apache.commons.lang3.StringUtils;
import org.apache.commons.lang3.exception.ExceptionUtils;
import org.apache.solr.client.solrj.util.ClientUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.curriki.api.enus.config.ConfigKeys;
import org.curriki.api.enus.request.SiteRequestEnUS;
import org.curriki.api.enus.request.api.ApiRequest;
import org.curriki.api.enus.search.SearchList;
import org.curriki.api.enus.user.SiteUser;
import org.curriki.api.enus.user.SiteUserEnUSApiServiceImpl;
import org.curriki.api.enus.vertx.MailVerticle;
import io.vertx.core.AsyncResult;
import io.vertx.core.Future;
import io.vertx.core.Handler;
import io.vertx.core.MultiMap;
import io.vertx.core.Promise;
import io.vertx.core.WorkerExecutor;
import io.vertx.core.buffer.Buffer;
import io.vertx.core.eventbus.DeliveryOptions;
import io.vertx.core.eventbus.EventBus;
import io.vertx.core.json.JsonArray;
import io.vertx.core.json.JsonObject;
import io.vertx.ext.auth.User;
import io.vertx.ext.auth.authorization.AuthorizationProvider;
import io.vertx.ext.auth.oauth2.OAuth2Auth;
import io.vertx.ext.web.api.service.ServiceRequest;
import io.vertx.ext.web.api.service.ServiceResponse;
import io.vertx.ext.web.client.WebClient;
import io.vertx.ext.web.templ.handlebars.HandlebarsTemplateEngine;
import io.vertx.pgclient.PgPool;
import io.vertx.sqlclient.Tuple;

/**
 **/

public class BaseApiServiceImpl {
}

Create the LOG field inside the BaseApiServiceImpl class

    protected static final Logger LOG = LoggerFactory.getLogger(BaseApiServiceImpl.class);

Create the eventBus field inside the BaseApiServiceImpl class

    protected EventBus eventBus;

Create the config field inside the BaseApiServiceImpl class

    protected JsonObject config;

Create the workerExecutor field inside the BaseApiServiceImpl class

    protected WorkerExecutor workerExecutor;

Create the pgPool field inside the BaseApiServiceImpl class

    protected PgPool pgPool;

Create the webClient field inside the BaseApiServiceImpl class

    protected WebClient webClient;

Create the oauth2AuthenticationProvider field inside the BaseApiServiceImpl class

    protected OAuth2Auth oauth2AuthenticationProvider;

Create the authorizationProvider field inside the BaseApiServiceImpl class

    protected AuthorizationProvider authorizationProvider;

Create the templateEngine field inside the BaseApiServiceImpl class

    protected HandlebarsTemplateEngine templateEngine;

Create the error method inside the BaseApiServiceImpl class

    public void error(SiteRequestEnUS siteRequest, Handler<AsyncResult<ServiceResponse>> eventHandler, Throwable ex) {
        JsonObject json = new JsonObject();
        JsonObject jsonError = new JsonObject();
        json.put("error", jsonError);
        jsonError.put("message", Optional.ofNullable(ex).map(Throwable::getMessage).orElse(null));
        if(siteRequest != null) {
            jsonError.put("userName", siteRequest.getUserName());
            jsonError.put("userFullName", siteRequest.getUserFullName());
            jsonError.put("requestUri", siteRequest.getRequestUri());
            jsonError.put("requestMethod", siteRequest.getRequestMethod());
            jsonError.put("params", Optional.ofNullable(siteRequest.getServiceRequest()).map(o -> o.getParams()).orElse(null));
        }
        LOG.error("error: ", ex);
        ServiceResponse responseOperation = new ServiceResponse(400, "BAD REQUEST", 
                Buffer.buffer().appendString(json.encodePrettily())
                , MultiMap.caseInsensitiveMultiMap().add("Content-Type", "application/json")
        );
        if(siteRequest != null) {
            DeliveryOptions options = new DeliveryOptions();
            options.addHeader(MailVerticle.MAIL_HEADER_SUBJECT, String.format("%s %s", config.getString(ConfigKeys.SITE_BASE_URL), Optional.ofNullable(ex).map(Throwable::getMessage).orElse(null)));
            eventBus.publish(MailVerticle.MAIL_EVENTBUS_ADDRESS, String.format("%s\n\n%s", json.encodePrettily(), ExceptionUtils.getStackTrace(ex)));
            if(eventHandler != null)
                eventHandler.handle(Future.succeededFuture(responseOperation));
        } else {
            if(eventHandler != null)
                eventHandler.handle(Future.succeededFuture(responseOperation));
        }
    }

Create the generateSiteRequestEnUS method inside the BaseApiServiceImpl class

    public SiteRequestEnUS generateSiteRequestEnUS(User user, ServiceRequest serviceRequest) {
        return generateSiteRequestEnUS(user, serviceRequest, serviceRequest.getParams().getJsonObject("body"));
    }

Create the generateSiteRequestEnUS method inside the BaseApiServiceImpl class

    public SiteRequestEnUS generateSiteRequestEnUS(User user, ServiceRequest serviceRequest, JsonObject body) {
        SiteRequestEnUS siteRequest = new SiteRequestEnUS();
        siteRequest.setWebClient(webClient);
        siteRequest.setJsonObject(body);
        siteRequest.setUser(user);
        siteRequest.setConfig(config);
        siteRequest.setServiceRequest(serviceRequest);
        siteRequest.initDeepSiteRequestEnUS(siteRequest);

        return siteRequest;
    }

Create the user method inside the BaseApiServiceImpl class

    public Future<SiteRequestEnUS> user(ServiceRequest serviceRequest) {
        Promise<SiteRequestEnUS> promise = Promise.promise();
        try {
            JsonObject userJson = serviceRequest.getUser();
            if(userJson == null) {
                SiteRequestEnUS siteRequest = generateSiteRequestEnUS(null, serviceRequest);
                promise.complete(siteRequest);
            } else {
                User token = User.create(userJson);
                oauth2AuthenticationProvider.authenticate(token.principal()).onSuccess(user -> {
                    authorizationProvider.getAuthorizations(user).onSuccess(b -> {
                        try {
                            JsonObject userAttributes = user.attributes();
                            JsonObject accessToken = userAttributes.getJsonObject("accessToken");
                            String userId = userAttributes.getString("sub");
                            SiteRequestEnUS siteRequest = generateSiteRequestEnUS(user, serviceRequest);
                            SearchList<SiteUser> searchList = new SearchList<SiteUser>();
                            searchList.setQuery("*:*");
                            searchList.setStore(true);
                            searchList.setC(SiteUser.class);
                            searchList.addFilterQuery("userId_indexedstored_string:" + ClientUtils.escapeQueryChars(userId));
                            searchList.promiseDeepSearchList(siteRequest).onSuccess(c -> {
                                SiteUser siteUser1 = searchList.getList().stream().findFirst().orElse(null);
                                SiteUserEnUSApiServiceImpl userService = new SiteUserEnUSApiServiceImpl(eventBus, config, workerExecutor, pgPool, webClient, oauth2AuthenticationProvider, authorizationProvider, templateEngine);

                                if(siteUser1 == null) {
                                    JsonObject jsonObject = new JsonObject();
                                    jsonObject.put("userName", accessToken.getString("preferred_username"));
                                    jsonObject.put("userFirstName", accessToken.getString("given_name"));
                                    jsonObject.put("userLastName", accessToken.getString("family_name"));
                                    jsonObject.put("userFullName", accessToken.getString("name"));
                                    jsonObject.put("userId", accessToken.getString("sub"));
                                    jsonObject.put("userEmail", accessToken.getString("email"));
                                    userDefine(siteRequest, jsonObject, false);

                                    SiteRequestEnUS siteRequest2 = siteRequest.copy();
                                    siteRequest2.setJsonObject(jsonObject);
                                    siteRequest2.initDeepSiteRequestEnUS(siteRequest);

                                    ApiRequest apiRequest = new ApiRequest();
                                    apiRequest.setRows(1);
                                    apiRequest.setNumFound(1L);
                                    apiRequest.setNumPATCH(0L);
                                    apiRequest.initDeepApiRequest(siteRequest2);
                                    siteRequest2.setApiRequest_(apiRequest);

                                    userService.postSiteUserFuture(siteRequest2, false).onSuccess(siteUser -> {
                                        siteRequest.setUserName(accessToken.getString("preferred_username"));
                                        siteRequest.setUserFirstName(accessToken.getString("given_name"));
                                        siteRequest.setUserLastName(accessToken.getString("family_name"));
                                        siteRequest.setUserEmail(accessToken.getString("email"));
                                        siteRequest.setUserId(accessToken.getString("sub"));
                                        siteRequest.setUserKey(siteUser.getPk());
                                        promise.complete(siteRequest);
                                    }).onFailure(ex -> {
                                        error(siteRequest, null, ex);
                                    });
                                } else {
                                    JsonObject jsonObject = new JsonObject();
                                    jsonObject.put("setUserName", accessToken.getString("preferred_username"));
                                    jsonObject.put("setUserFirstName", accessToken.getString("given_name"));
                                    jsonObject.put("setUserLastName", accessToken.getString("family_name"));
                                    jsonObject.put("setUserCompleteName", accessToken.getString("name"));
                                    jsonObject.put("setUserId", accessToken.getString("sub"));
                                    jsonObject.put("setUserEmail", accessToken.getString("email"));
                                    Boolean define = userDefine(siteRequest, jsonObject, true);
                                    if(define) {

                                        SiteRequestEnUS siteRequest2 = siteRequest.copy();
                                        siteRequest2.setJsonObject(jsonObject);
                                        siteRequest2.initDeepSiteRequestEnUS(siteRequest);
                                        siteUser1.setSiteRequest_(siteRequest2);

                                        ApiRequest apiRequest = new ApiRequest();
                                        apiRequest.setRows(1);
                                        apiRequest.setNumFound(1L);
                                        apiRequest.setNumPATCH(0L);
                                        apiRequest.initDeepApiRequest(siteRequest2);
                                        siteRequest2.setApiRequest_(apiRequest);

                                        userService.patchSiteUserFuture(siteUser1, false).onSuccess(siteUser2 -> {
                                            siteRequest.setUserName(siteUser2.getUserName());
                                            siteRequest.setUserFirstName(siteUser2.getUserFirstName());
                                            siteRequest.setUserLastName(siteUser2.getUserLastName());
                                            siteRequest.setUserKey(siteUser2.getPk());
                                            promise.complete(siteRequest);
                                        }).onFailure(ex -> {
                                            promise.fail(ex);
                                        });
                                    } else {
                                        siteRequest.setUserName(siteUser1.getUserName());
                                        siteRequest.setUserFirstName(siteUser1.getUserFirstName());
                                        siteRequest.setUserLastName(siteUser1.getUserLastName());
                                        siteRequest.setUserKey(siteUser1.getPk());
                                        promise.complete(siteRequest);
                                    }
                                }
                            }).onFailure(ex -> {
                                LOG.error(String.format("user failed. "), ex);
                                promise.fail(ex);
                            });
                        } catch(Exception ex) {
                            LOG.error(String.format("user failed. "), ex);
                            promise.fail(ex);
                        }
                    }).onFailure(ex -> {
                        LOG.error(String.format("user failed. ", ex));
                        promise.fail(ex);
                    });
                }).onFailure(ex -> {
                    oauth2AuthenticationProvider.refresh(token).onSuccess(user -> {
                        serviceRequest.setUser(user.principal());
                        user(serviceRequest).onSuccess(siteRequest -> {
                            promise.complete(siteRequest);
                        }).onFailure(ex2 -> {
                            LOG.error(String.format("user failed. ", ex2));
                            promise.fail(ex2);
                        });
                    }).onFailure(ex2 -> {
                        promise.fail(new RuntimeException(ex2.getMessage(), ex2));
                    });
                });
            }
        } catch(Exception ex) {
            LOG.error(String.format("user failed. "), ex);
            promise.fail(ex);
        }
        return promise.future();
    }

Create the userDefine method inside the BaseApiServiceImpl class

    public Boolean userDefine(SiteRequestEnUS siteRequest, JsonObject jsonObject, Boolean patch) {
        return false;
    }

Create the attributeArrayFuture method inside the BaseApiServiceImpl class

    public void attributeArrayFuture(SiteRequestEnUS siteRequest, Class<?> c1, Long pk1, Class<?> c2, String pk2, List<Future<?>> futures, String entityVar, Boolean inheritPk) {
        ApiRequest apiRequest = siteRequest.getApiRequest_();
        List<Long> pks = apiRequest.getPks();

        for(String l : Optional.ofNullable(siteRequest.getJsonObject().getJsonArray(entityVar)).orElse(new JsonArray()).stream().map(a -> (String)a).collect(Collectors.toList())) {
            if(l != null) {
                SearchList<BaseModel> searchList = new SearchList<BaseModel>();
                searchList.setQuery("*:*");
                searchList.setStore(true);
                searchList.setC(BaseModel.class);
                searchList.addFilterQuery("classSimpleName_indexedstored_string:" + ClientUtils.escapeQueryChars(c2.getSimpleName()));
                searchList.addFilterQuery((inheritPk ? "inheritPk_indexedstored_string:" : "pk_indexedstored_long:") + ClientUtils.escapeQueryChars(l));
                searchList.promiseDeepSearchList(siteRequest).onSuccess(s -> {
                    Long l2 = Optional.ofNullable(searchList.getList().stream().findFirst().orElse(null)).map(a -> a.getPk()).orElse(null);
                    if(l2 != null) {
                        futures.add(siteRequest.getSqlConnection().preparedQuery(String.format("UPDATE %s SET %s=$1 WHERE pk=$2", c1.getSimpleName(), entityVar)).execute(Tuple.of(pk1, l2)));
                        if(!pks.contains(l2)) {
                            pks.add(l2);
                            apiRequest.getClasses().add(c2.getSimpleName());
                        }
                    }
                }).onFailure(ex -> {
                    LOG.error("update %s failed. ", entityVar);
                });
            }
        }
    }

Create the sql method inside the BaseApiServiceImpl class

    public SqlUpdate sql(SiteRequestEnUS siteRequest) {
        return new SqlUpdate(siteRequest);
    }

Create the search method inside the BaseApiServiceImpl class

    public SearchQuery search(SiteRequestEnUS siteRequest) {
        return new SearchQuery(siteRequest);
    }

This message will not self destruct, because this project is open source.