Complete PACE implementation

Author: andrewrjones

initdb.d/init.sql

@@ -2,6 +2,4 @@ create user mark with encrypted password 'mark';
 create role administrator;
 create role marketing;
 grant marketing to mark;
-grant administrator to postgres;
--- Grant select access to user 'other' on all (including future) tables
--- alter default privileges in schema public grant all on tables to other;
+grant administrator to postgres;

lib/data_contract.py

@@ -67,4 +67,51 @@ def to_datacontract_cli(contract):
  }
 
 
- return data
+ return data
+
+def to_pace(contract):
+ # The schema
+ fields = []
+ for column in contract["columns"]:
+ fields.append({
+ 'name_parts': [column["name"]],
+ 'type': column["data_type"].lower(),
+ })
+
+ # The access policies
+ conditions = []
+ for policy in contract["access"]:
+ conditions.append(dict(
+ principals = policy.get("principals", []),
+ condition = policy.get("condition")
+ ))
+
+ filters = [dict(
+ generic_filter = dict(
+ conditions = conditions
+ )
+ )]
+
+ return dict(
+ metadata = dict(
+ title = f"public.{contract['dataset']}",
+ ),
+ source = dict(
+ ref = dict(
+ integration_fqn = f"public.{contract['dataset']}",
+ platform = dict(
+ id = "postgres",
+ platform_type = "POSTGRES",
+ )
+ ),
+ fields = fields,
+ ),
+ rule_sets = [dict(
+ target = dict(
+ ref = dict(
+ integration_fqn = f"public.{contract['dataset']}_view",
+ ),
+ ),
+ filters = filters,
+ )]
+ )

pace/application.yaml

@@ -1,6 +1,6 @@
 spring:
  datasource:
- url: jdbc:postgresql://postgres_pace:5431/pace
+ url: jdbc:postgresql://postgres_pace:5432/pace
  hikari:
  username: pace
  password: pace
@@ -10,7 +10,7 @@ app:
  expose-application-exceptions: true
  processing-platforms:
  postgres:
- - id: "sample-connection"
+ - id: "postgres"
  host-name: "postgres"
  port: 5432
  user-name: "postgres"