Skip to content
Snippets Groups Projects
Code owners
Assign users and groups as approvers for specific file changes. Learn more.
Name Last commit Last update
..
cloudbuild
docker
docs
scripts
src
README.md
pom.xml

Notification Service

notification-gcp is a Spring Boot service that allow for interested consumers to subscribe to data and metadata changes using a publish/subscriber pattern.

Table of Contents

Getting Started

These instructions will get you a copy of the project up and running on your local machine for development and testing purposes. See deployment for notes on how to deploy the project on a live system.

Mappers

This is a universal solution created using EPAM OQM mapper technology. It allows you to work with various implementations of message brokers.

For more information about mappers:

In the current version, the OQM mapper is equipped with 2 drivers to the message brokers:

  • Google PubSub;
  • RabbitMQ

Settings and Configuration

Requirements

  1. Mandatory

  2. For Google Cloud only

    • GCloud command line tool
    • GCloud access to opendes project

Anthos Service Configuration:

Anthos service configuration

GCP Service Configuration:

Gcp service configuration

Run service

Running Locally

Check that maven is installed:

$ mvn --version
Apache Maven 3.6.0
Maven home: /usr/share/maven
Java version: 1.8.0_212, vendor: AdoptOpenJDK, runtime: /usr/lib/jvm/jdk8u212-b04/jre
...

You will need to configure access to the remote maven repository that holds the OSDU dependencies. This file should live within ~/.m2/settings.xml:

$ cat ~/.m2/settings.xml
<?xml version="1.0" encoding="UTF-8"?>
<settings xmlns="http://maven.apache.org/SETTINGS/1.0.0"
          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
          xsi:schemaLocation="http://maven.apache.org/SETTINGS/1.0.0 http://maven.apache.org/xsd/settings-1.0.0.xsd">
    <servers>
        <server>
            <id>os-core</id>
            <username>slb-des-ext-collaboration</username>
            <!-- Treat this auth token like a password. Do not share it with anyone, including Microsoft support. -->
            <password>${VSTS_FEED_TOKEN}</password>
        </server>
    </servers>
</settings>
  • Update the Google cloud SDK to the latest version:
gcloud components update
  • Set Google Project Id:
gcloud config set project <YOUR-PROJECT-ID>
  • Perform a basic authentication in the selected project:
gcloud auth application-default login
  • Navigate to notification service's root folder and run:
mvn jetty:run
## Testing
* Navigate to notification service's root folder and run:
 
```bash
mvn clean install   
  • If you wish to see the coverage report then go to testing/target/site/jacoco-aggregate and open index.html

  • If you wish to build the project without running tests

mvn clean install -DskipTests

After configuring your environment as specified above, you can follow these steps to build and run the application. These steps should be invoked from the repository root.

cd provider/notification-gcp/ && mvn spring-boot:run -Dspring-boot.run.profiles=local 

Testing

Navigate to notification service's root folder and run all the tests:

# build + test + install core service code
$ (cd notification-core/ && mvn clean install)

Test the application

After the service has started it should be accessible via a web browser by visiting http://localhost:8080/api/notification/v1/swagger-ui.html. If the request does not fail, you can then run the integration tests.

Dependencies needed to run the integration tests

  • Java 8
  • Maven
  • Values for the following environment variables in Config.java
name value description sensitive? source
DE_OPS_TESTER ***** Service account base64 encoded string for API calls. Note: this user must have entitlements configured already, also Private key id of this account must be set in Register service variable SUBSCRIBER_PRIVATE_KEY_ID yes https://console.cloud.google.com/iam-admin/serviceaccounts
DE_ADMIN_TESTER ***** Service account base64 encoded string for API calls. Note: this user must have entitlements configured already yes https://console.cloud.google.com/iam-admin/serviceaccounts
DE_EDITOR_TESTER ***** Service account base64 encoded string for API calls. Note: this user must have entitlements configured already yes https://console.cloud.google.com/iam-admin/serviceaccounts
DE_NO_ACCESS_TESTER ***** Service account base64 encoded string for API calls. Note: this user must have entitlements configured already yes https://console.cloud.google.com/iam-admin/serviceaccounts
ENVIRONMENT dev OR local OR dev_gke Local for running locally with services url's predefined as http://localhost , Dev & Dev_Gke is configurable environment no -
HMAC_SECRET ex7a786376626e String in hex , must match pattern ^[a-zA-Z0-9]{8,30}+$ & be in register variable SUBSCRIBER_SECRET yes -
REGISTER_BASE_URL http://localhost:8081/api/register/v1 Register service url no -
NOTIFICATION_BASE_URL http://localhost:8080/api/notification/v1/ Notification service url no -
INTEGRATION_TEST_AUDIENCE ******** Client application ID yes https://console.cloud.google.com/apis/credentials
CLIENT_TENANT ex opendes Client tenant no -
OSDU_TENANT ex osdu Osdu tenant no -
TOPIC_ID ex records-changed PubSub topic id no https://console.cloud.google.com/cloudpubsub/topic
REGISTER_CUSTOM_PUSH_URL_HMAC ex http://localhost:8081/api/register/v1/test/challenge/hmac-integration-test Register testing push url no -

Entitlements configuration for integration accounts

DE_OPS_TESTER DE_ADMIN_TESTER DE_EDITOR_TESTER DE_NO_ACCESS_TESTER
notification.pubsub
service.entitlements.user
users
users.datalake.ops
service.entitlements.user
users
users.datalake.admins
service.entitlements.user
users
users.datalake.editors
service.entitlements.user
users

Above variables should be configured in the release pipeline to run integration tests. You should also replace them with proper values if you wish to run tests locally.

Commands to run tests

  • Integration tests are refactored into two pieces: Core and Provider. Core contains business logic for tests and is a dependency for executing the tests from provider module. To build the core module, simply navigate to notification-test-core directory and run mvn clean install. This will build the core module
  • Next, to execute the integration tests, navigate to the provider module and execute mvn test
# (cd testing/notification-test-core/ && mvn clean install)
# Note: this assumes that the environment variables for integration tests as outlined
#       above are already exported in your environment.
$ (cd testing/notification-test-gcp/ && mvn clean test)

Tutorial

Entitlements groups

Notification service account should have entitlements groups listed below:

  • users
  • users.datalake.editors
  • service.entitlements.user

License

Copyright © Google LLC

Copyright © EPAM Systems

Licensed 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.