Clickhouse support.

Author: EvgSkv

common/clickhouse_logica.py

@@ -21,7 +21,7 @@
 settings or via environment variables.
 
 Environment variables:
-  LOGICA_CLICKHOUSE_HOST (default: 127.0.0.1)
+  LOGICA_CLICKHOUSE_HOST (default: 127.0.0.1; may include http:// or https://)
   LOGICA_CLICKHOUSE_PORT (default: 8123)
   LOGICA_CLICKHOUSE_USER (default: default)
   LOGICA_CLICKHOUSE_PASSWORD (default: "")
@@ -186,7 +186,18 @@ def HttpRequest(sql, *, settings):
     if v is None:
       continue
     params[str(k)] = str(v)
-  url = f"http://{settings['host']}:{settings['port']}/?" + urllib.parse.urlencode(params)
+  host = str(settings['host'])
+  port = int(settings['port'])
+  scheme = 'http'
+  if '://' in host:
+    parsed = urllib.parse.urlparse(host)
+    scheme = parsed.scheme or scheme
+    host = parsed.hostname or host
+    port = int(parsed.port or (443 if scheme == 'https' else port))
+
+  base_url = f'{scheme}://{host}:{port}'
+
+  url = base_url.rstrip('/') + '/?' + urllib.parse.urlencode(params)
   req = urllib.request.Request(
       url,
       data=(sql + "\n").encode('utf-8'),

examples/scripts/path_explanation_demo.l

@@ -0,0 +1,49 @@
+#!/usr/bin/env logica
+#
+# Copyright 2026 Logica Authors
+#
+# 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.
+
+@Engine("sqlite");
+
+# Explainable paths demo: "why does A depend on B?"
+#
+# We compute a shortest witness path as an array of nodes.
+
+Depends("frontend", "api");
+Depends("api", "billing");
+Depends("billing", "payments_db");
+Depends("api", "events");
+Depends("events", "analytics");
+
+# Shortest path search (same pattern as integration_tests/sqlite_reachability.l).
+Path(source:, target:, length? Min= 1, path? ArgMin= ([source] -> 1)) distinct :-
+  Depends(source, target);
+
+Path(source: a, target: c,
+     length? Min= l1 + l2,
+     path? ArgMin= ArrayConcat(p1, p2) -> (l1 + l2)) distinct :-
+  Path(source: a, target: b, length: l1, path: p1),
+  Path(source: b, target: c, length: l2, path: p2);
+
+Explain(source:, target:, witness_path:) :-
+  Path(source:, target:, path: p),
+  witness_path == ArrayConcat(p, [target]),
+  source != target;
+
+# One concrete "why" question.
+WhyFrontendToDb(witness_path) :-
+  Explain(source: "frontend", target: "payments_db", witness_path: witness_path);
+
+Q(source:, target:, witness_path:) :-
+  Explain(source:, target:, witness_path:);

examples/scripts/team_contracts_demo.l

@@ -0,0 +1,84 @@
+#!/usr/bin/env logica
+#
+# Copyright 2026 Logica Authors
+#
+# 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.
+
+@Engine("sqlite");
+
+# A tiny demo of "team contracts": promises vs requirements.
+# The output is a list of objectively checkable violations.
+
+Team("billing");
+Team("risk");
+Team("analytics");
+
+System("charge_api");
+System("events_stream");
+
+Owns("billing", "charge_api");
+Owns("analytics", "events_stream");
+
+# Promises: what the owner team claims to provide.
+# Example: latency_p95_ms <= 200
+PromiseSla("billing", "charge_api", "latency_p95_ms", 200);
+PromiseSla("analytics", "events_stream", "delivery_lag_p95_s", 60);
+
+# Requirements: what a consumer team needs.
+NeedSla("risk", "charge_api", "latency_p95_ms", 150);
+NeedSla("billing", "events_stream", "delivery_lag_p95_s", 10);
+
+# Schema promises/requirements (simplified).
+PromiseFieldType("billing", "charge_api", "amount", "Int64");
+NeedFieldType("risk", "charge_api", "amount", "Float64");
+
+# Violations.
+SlaViolation(consumer, owner, system, metric, need, promise) :-
+  NeedSla(consumer, system, metric, need),
+  Owns(owner, system),
+  PromiseSla(owner, system, metric, promise),
+  need < promise;
+
+MissingPromise(consumer, owner, system, metric, need) :-
+  NeedSla(consumer, system, metric, need),
+  Owns(owner, system),
+  ~PromiseSla(owner, system, metric, _);
+
+TypeViolation(consumer, owner, system, field, need_type, promise_type) :-
+  NeedFieldType(consumer, system, field, need_type),
+  Owns(owner, system),
+  PromiseFieldType(owner, system, field, promise_type),
+  need_type != promise_type;
+
+Q(kind, consumer, owner, system, subject, expected, actual) :-
+  SlaViolation(consumer, owner, system, metric, need, promise),
+  kind == "sla",
+  subject == metric,
+  expected == ToString(need),
+  actual == ToString(promise);
+
+Q(kind, consumer, owner, system, subject, expected, actual) :-
+  MissingPromise(consumer, owner, system, metric, need),
+  kind == "missing_promise",
+  subject == metric,
+  expected == ToString(need),
+  actual == "(no promise)";
+
+Q(kind, consumer, owner, system, subject, expected, actual) :-
+  TypeViolation(consumer, owner, system, field, need_type, promise_type),
+  kind == "type",
+  subject == field,
+  expected == need_type,
+  actual == promise_type;
+
+@OrderBy(Q, "col0");