Skip to content
Closed
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion gradle.properties
Original file line number Diff line number Diff line change
@@ -1,3 +1,3 @@
micronautVersion=4.8.3
justserveCliVersion=0.0.7
justserveCliVersion=0.0.8-SNAPSHOT
org.gradle.console=rich
7 changes: 2 additions & 5 deletions src/main/java/org/justserve/cli/JustServeCommand.java
Original file line number Diff line number Diff line change
@@ -1,16 +1,13 @@
package org.justserve.cli;

import io.micronaut.configuration.picocli.PicocliRunner;
import org.justserve.cli.command.BaseCommand;
import org.justserve.cli.command.GetTempPassword;
import org.justserve.cli.command.MakeOrgAdmin;
import org.justserve.cli.command.UnReassignProjects;
import org.justserve.cli.command.*;
import org.justserve.cli.util.JustServeVersionProvider;
import picocli.CommandLine.Command;
import picocli.CommandLine.ParameterException;
import picocli.jansi.graalvm.AnsiConsole;

@Command(subcommands = {GetTempPassword.class, MakeOrgAdmin.class, UnReassignProjects.class},
@Command(subcommands = {GetTempPassword.class, MakeOrgAdmin.class, UnReassignProjects.class, AssignOrgToProject.class},
mixinStandardHelpOptions = true,
name = "justserve", versionProvider = JustServeVersionProvider.class,
description = "justserve-cli is a terminal tool to help specialists and admin using JustServe")
Expand Down
57 changes: 57 additions & 0 deletions src/main/java/org/justserve/cli/command/AssignOrgToProject.java
Original file line number Diff line number Diff line change
@@ -0,0 +1,57 @@
package org.justserve.cli.command;

import io.micronaut.http.HttpResponse;
import io.micronaut.http.HttpStatus;
import io.micronaut.http.client.exceptions.HttpClientResponseException;
import jakarta.inject.Inject;
import jakarta.inject.Provider;
import lombok.extern.slf4j.Slf4j;
import org.justserve.client.ProjectClient;
import picocli.CommandLine.Command;
import picocli.CommandLine.Option;

import java.util.UUID;

import static org.justserve.cli.util.JustServePrinter.printError;
import static org.justserve.cli.util.JustServePrinter.printNormal;

@Slf4j
@Command(name = "assignOrgToProject", description = "Assigns an organization to a project", mixinStandardHelpOptions = true)
public class AssignOrgToProject extends BaseCommand implements Runnable {

@Option(names = {"--project", "-p"}, description = "the project ID", required = true)
private UUID projectId;

@Option(names = {"--org", "-o"}, description = "the organization ID", required = true)
private UUID orgId;

@Inject
Provider<ProjectClient> projectClientProvider;

@Override
public void run() {
if (isTokenInvalid()) {
return;
}

ProjectClient client = projectClientProvider.get();

try {
log.atTrace().log("Assigning organization {} to project {}", orgId, projectId);
HttpResponse<Object> response = client.assignOrganizationToProject(projectId, orgId);
if (response.status() == HttpStatus.OK) {
printNormal("Successfully assigned organization %s to project %s", orgId, projectId);
log.atTrace().log("received api response status: {}", response.status());
} else {
printError("Failed to assign organization " + orgId + " to project " + projectId +
". Expected HTTP Status 'OK', but got " + response.status());
log.atError().log("Failed to assign organization {} to project {}. Expected HTTP Status 'OK', but got {}",
orgId, projectId, response.status());
}
} catch (HttpClientResponseException e) {
printError("Failed to assign organization %s to project %s. (%s: %s)",
orgId, projectId, e.getStatus().getCode(), e.getMessage());
log.atError().setCause(e).log("Error response from API: {}", e.getResponse().body());
}
}
}
34 changes: 16 additions & 18 deletions src/main/java/org/justserve/cli/command/MakeOrgAdmin.java
Original file line number Diff line number Diff line change
Expand Up @@ -45,24 +45,22 @@ public void run() {
}
DynamicRoutingClient dynamicRoutingClient = dynamicRoutingClientProvider.get();
// since we allow submitting orgId's and orgUrl, convert any slugs to orgId's
Map<Org, @Nullable UUID> orgUuidMap = Arrays.stream(orgs).distinct().parallel()
.collect(Collectors.toMap(
org -> org,
org -> org instanceof OrgId ? ((OrgId) org).getId() : dynamicRoutingClient
.getOrgIdFromSlug(((OrgSlug) org).getSlug()).body().getId()
));
if (orgUuidMap.values().stream().anyMatch(Objects::isNull)) {
// provide a list of all invalid org slugs, not just the first failure
List<OrgSlug> invalidOrgSlugs = new ArrayList<>();
orgUuidMap.entrySet().stream()
.filter(entry -> entry.getValue() == null)
.map(entry -> (OrgSlug) entry.getKey())
.forEach(invalidOrgSlugs::add);
printError("The following organization slugs are invalid: " + invalidOrgSlugs.stream()
.map(OrgSlug::getSlug)
.collect(Collectors.joining(", ")));
return;
}
Map<Org, UUID> orgUuidMap = Arrays.stream(orgs).distinct().parallel()
.map(org -> {
if (org instanceof OrgId) {
return new AbstractMap.SimpleEntry<>(org, ((OrgId) org).getId());
}
try {
return new AbstractMap.SimpleEntry<>(org, dynamicRoutingClient
.getOrgIdFromSlug(((OrgSlug) org).getSlug()).body().getId());
} catch (NullPointerException noOrgFound) {
err(String.format("The org '%s' is not found on JustServe", ((OrgSlug) org).getSlug()));
return null;
}
})
.filter(Objects::nonNull)
.collect(Collectors.toMap(Map.Entry::getKey, Map.Entry::getValue));

log.atTrace().log("Finished converting any slugs to org id's.");
BoundaryPermissionClient boundaryPermissionClient = boundaryPermissionClientProvider.get();
Map<Org, @Nullable UUID> successfulReassignments = new HashMap<>();
Expand Down
2 changes: 1 addition & 1 deletion src/main/resources/logback.xml
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,7 @@
</encoder>
</appender>

<root level="WARN">
<root level="OFF">
<appender-ref ref="STDOUT" />
</root>
</configuration>
29 changes: 26 additions & 3 deletions src/main/resources/schema.yml
Original file line number Diff line number Diff line change
Expand Up @@ -150,6 +150,29 @@ paths:
application/json:
schema:
type: null
/api/v1/projects/{id}/organization/{organizationId}/assign:
put:
tags: [ Project ]
description: Assigns an organization to a project.
operationId: assignOrganizationToProject
parameters:
- name: id
in: path
description: ID of the project
required: true
schema: { type: string, format: uuid }
- name: organizationId
in: path
description: ID of the organization to assign
required: true
schema: { type: string, format: uuid }
responses:
'200':
description: OK
content:
application/json:
schema:
type: null
/api/v1/users:
post:
description: Register a new user on JustServe
Expand Down Expand Up @@ -857,8 +880,8 @@ components:
organizationType: { $ref: '#/components/schemas/OrganizationType' }
title: { type: string, nullable: true }
logo: { type: string, nullable: true }
url: { type: string, nullable: true }
internalURL: { type: string, nullable: true }
url: { type: string, nullable: true, description: "this provides only the url slug" }
internalURL: { type: string, nullable: true, description: "this currently returns null when an org is searched for by location" }
website: { type: string, nullable: true }
description: { type: string, nullable: true }
contactName: { type: string, nullable: true }
Expand Down Expand Up @@ -1231,7 +1254,7 @@ components:
description: {}
url: {}
internalUrl: {}
organizationId: {}
organizationId: { type: string, format: uuid }
reviewedBy: {}
reviewedOn: {}
linked:
Expand Down
2 changes: 1 addition & 1 deletion src/test/groovy/org/justserve/JustServeSpec.groovy
Original file line number Diff line number Diff line change
Expand Up @@ -159,7 +159,7 @@ class JustServeSpec extends Specification {
* @param count The number of organizations to create.
* @return A list of UUIDs for the created organizations.
*/
List<UUID> createOrgs(int count) {
List<UUID> createTestOrgs(int count) {
return (1..count).collect {
createOrg()
}
Expand Down
Original file line number Diff line number Diff line change
@@ -0,0 +1,40 @@
package org.justserve.cli.command

import io.micronaut.test.extensions.spock.annotation.MicronautTest
import org.justserve.model.ProjectCard
import spock.lang.Execution

import static org.spockframework.runtime.model.parallel.ExecutionMode.SAME_THREAD

@Execution(SAME_THREAD)
@MicronautTest
class AssignOrgToProjectSpec extends BaseCommandSpec {

def "can assign an organization to a project"() {
given:
def orgSearchResponse = authOrgClient.searchByLocation(createSearchRequestForElkGrove())
UUID orgId = orgSearchResponse.body().organizations.first().id
ProjectCard project = searchResults.first()
def args = ["assignOrgToProject", "-p", project.getId().toString(), "-o", orgId.toString()]

when:
def (outputStream, errorStream) = executeCommand(ctx, args as String[])

then:
errorStream.matches(blankRegex)
outputStream.contains("Successfully assigned organization ${orgId} to project ${project.getId()}")
}

def "fails gracefully when project or org does not exist"() {
given:
UUID fakeId = UUID.randomUUID()
def args = ["assignOrgToProject", "-p", fakeId.toString(), "-o", fakeId.toString()]

when:
def (outputStream, errorStream) = executeCommand(ctx, args as String[])

then:
outputStream.matches(blankRegex)
errorStream.contains("Failed to assign organization ${fakeId} to project ${fakeId}. (400: Client 'justserve': Bad Request)")
}
}
35 changes: 33 additions & 2 deletions src/test/groovy/org/justserve/cli/command/MakeOrgAdminSpec.groovy
Original file line number Diff line number Diff line change
Expand Up @@ -11,7 +11,7 @@ class MakeOrgAdminSpec extends BaseCommandSpec {
def "can make a user an admin to #orgCount org(s) using the #orgFlag and #userFlag flags #title"() {
given:
UUID userID = createUser().body().id
def orgs = createOrgs(orgCount).join(",")
def orgs = createTestOrgs(orgCount).join(",")

when:
def (outputStream, errorStream) = executeCommand(context as ApplicationContext, ["makeOrgAdmin", orgFlag, orgs, userFlag, userID] as String[])
Expand Down Expand Up @@ -53,7 +53,7 @@ class MakeOrgAdminSpec extends BaseCommandSpec {
if (orgCount == 1) {
orgs = fakeId
} else {
orgs = createOrgs(orgCount - 1).join(",") + "," + fakeId
orgs = createTestOrgs(orgCount - 1).join(",") + "," + fakeId
}

when:
Expand All @@ -75,4 +75,35 @@ class MakeOrgAdminSpec extends BaseCommandSpec {
"-o" | 1 | "--user" | ctx | "as an authorized user successfully makes the changes" | _
}



def "can make a user an admin to #orgCount where at least one org Slug does not exist on JustServe"() {
given:
UUID userID = createUser().body().id
String orgs
def fakeSlug = faker.internet().slug().toString()
if (orgCount == 1) {
orgs = fakeSlug
} else {
orgs=authOrgClient.searchByLocation(createSearchRequestForElkGrove()).body().getOrganizations().url.take(orgCount - 1).join(",")+","+fakeSlug
}

when:
def (outputStream, errorStream) = executeCommand(context as ApplicationContext, ["makeOrgAdmin", orgFlag, orgs, userFlag, userID] as String[])

then:
verifyAll {
(outputStream as String).contains("successfully reassigned ${orgCount - 1 } orgs to user ${userID}")
(errorStream as String).contains("Error The org '${fakeSlug}' is not found on JustServe")
}

where:
orgFlag | orgCount | userFlag | context | title | _
"-o" | 3 | "-u" | ctx | "as an authorized user successfully makes the changes" | _
"--org" | 3 | "-u" | ctx | "as an authorized user successfully makes the changes" | _
"-o" | 3 | "--user" | ctx | "as an authorized user successfully makes the changes" | _
"-o" | 1 | "-u" | ctx | "as an authorized user successfully makes the changes" | _
"--org" | 1 | "-u" | ctx | "as an authorized user successfully makes the changes" | _
"-o" | 1 | "--user" | ctx | "as an authorized user successfully makes the changes" | _
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -11,27 +11,30 @@ class DynamicRoutingClientSpec extends JustServeSpec {
@Shared
DynamicRoutingClient noAuthClient, authClient

@Shared
String realOrgSlug


def setupSpec() {
noAuthClient = noAuthCtx.getBean(DynamicRoutingClient)
authClient = ctx.getBean(DynamicRoutingClient)
realOrgSlug = authOrgClient.searchByLocation(createSearchRequestForElkGrove()).body().getOrganizations().url.first().toString()
}

def "get orgId for #url"() {
when:
HttpResponse<DynamicRoutingDataResponse> response = client.getOrgIdFromSlug(url)

then:
response.status() == expectedStatus
if (expectedStatus == HttpStatus.OK) {
response.body().id != null
}

where:
url | expectedStatus | client
"accessleisure_sacramento" | HttpStatus.OK | authClient //TODO add actual orgs, not hardtyped ones
"accessleisure_sacramento" | HttpStatus.OK | noAuthClient
"1234" | HttpStatus.NOT_FOUND | authClient
"1234" | HttpStatus.NOT_FOUND | noAuthClient
url | expectedStatus | client
realOrgSlug | HttpStatus.OK | authClient
realOrgSlug | HttpStatus.OK | noAuthClient
"1234" | HttpStatus.NOT_FOUND | authClient
"1234" | HttpStatus.NOT_FOUND | noAuthClient
}
}
21 changes: 21 additions & 0 deletions src/test/groovy/org/justserve/client/ProjectClientSpec.groovy
Original file line number Diff line number Diff line change
Expand Up @@ -73,4 +73,25 @@ class ProjectClientSpec extends JustServeSpec {
}
}

void "can assign an organization to a project"() {
given:
def orgSearchResponse = authOrgClient.searchByLocation(createSearchRequestForElkGrove())
UUID orgId = orgSearchResponse.body().organizations.first().id
ProjectCard project = searchResults.first()

when:
def response = projectClient.assignOrganizationToProject(project.getId(), orgId)

then:
verifyAll {
response.status == OK
}

and: "validate that the reassignment worked - this is testing the underlying tech, not our codebase"
def updatedProject = projectClient.getProject(project.getId(), "en-US", new GetProjectRequest()).body()
verifyAll {
updatedProject.organization.organizationId == orgId
}
}

}
Loading