feat: initial SDK scaffold — v0.1.0

Author: ThreadSync Engineering

.gitignore

@@ -0,0 +1,6 @@
+__pycache__
+dist
+*.egg-info
+.env
+.venv
+venv

LICENSE

@@ -0,0 +1,21 @@
+MIT License
+
+Copyright (c) 2026 Cichocki
+
+Permission is hereby granted, free of charge, to any person obtaining a copy
+of this software and associated documentation files (the "Software"), to deal
+in the Software without restriction, including without limitation the rights
+to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+copies of the Software, and to permit persons to whom the Software is
+furnished to do so, subject to the following conditions:
+
+The above copyright notice and this permission notice shall be included in all
+copies or substantial portions of the Software.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
+SOFTWARE.

README.md

@@ -0,0 +1,69 @@
+# ThreadSync Python SDK
+
+[![PyPI](https://img.shields.io/pypi/v/threadsync)](https://pypi.org/project/threadsync/)
+[![license](https://img.shields.io/pypi/l/threadsync)](./LICENSE)
+[![python](https://img.shields.io/pypi/pyversions/threadsync)](https://pypi.org/project/threadsync/)
+
+Official Python SDK for the [ThreadSync API](https://www.threadsync.io/api-docs.html).
+
+## Installation
+
+```bash
+pip install threadsync
+```
+
+## Quick Start
+
+```python
+from threadsync import ThreadSync
+
+client = ThreadSync(bearer_token='YOUR_API_KEY')
+
+# Create a connection
+connection = client.connections.create(
+    'salesforce',
+    credentials={'username': 'user@example.com', 'password': 'secret'}
+)
+
+# Set up a sync
+sync = client.sync.create(
+    source={'connection': connection.id, 'object': 'Contact'},
+    destination={'connection': 'dest-conn-id', 'table': 'contacts'},
+    schedule='realtime',
+)
+
+print(f'Sync started: {sync.id}')
+```
+
+## API Reference
+
+### `ThreadSync(bearer_token, base_url=...)`
+
+| Parameter | Type | Required | Description |
+|-----------|------|----------|-------------|
+| `bearer_token` | `str` | Yes | Your ThreadSync API key |
+| `base_url` | `str` | No | Override the API base URL (default: `https://api.threadsync.io/v1`) |
+
+### `client.connections`
+
+| Method | Description |
+|--------|-------------|
+| `connections.create(provider, **kwargs)` | Create a new connection |
+| `connections.get(id)` | Retrieve a connection by ID |
+| `connections.list()` | List all connections |
+
+### `client.sync`
+
+| Method | Description |
+|--------|-------------|
+| `sync.create(source, destination, schedule)` | Create a new sync job |
+| `sync.get(id)` | Retrieve a sync by ID |
+
+## Links
+
+- [API Documentation](https://www.threadsync.io/api-docs.html)
+- [ThreadSync Website](https://www.threadsync.io)
+
+## License
+
+MIT — see [LICENSE](./LICENSE)

pyproject.toml

@@ -0,0 +1,19 @@
+[build-system]
+requires = ["setuptools>=68", "wheel"]
+build-backend = "setuptools.backends.legacy:build"
+
+[project]
+name = "threadsync"
+version = "0.1.0"
+description = "Official Python SDK for the ThreadSync API"
+readme = "README.md"
+license = { file = "LICENSE" }
+requires-python = ">=3.8"
+dependencies = [
+    "httpx>=0.24",
+]
+
+[project.urls]
+Homepage = "https://www.threadsync.io"
+Documentation = "https://www.threadsync.io/api-docs.html"
+Repository = "https://github.com/threadsync-infrastructure/threadsync-python"

threadsync/__init__.py

@@ -0,0 +1,4 @@
+from .client import ThreadSync, Connection, Sync
+
+__version__ = '0.1.0'
+__all__ = ['ThreadSync', 'Connection', 'Sync']

threadsync/client.py

@@ -0,0 +1,64 @@
+import httpx
+from dataclasses import dataclass
+from typing import Optional, Any
+
+@dataclass
+class Connection:
+    id: str
+    provider: str
+    name: str
+    status: str
+
+@dataclass
+class Sync:
+    id: str
+    status: str
+    records_synced: Optional[int] = None
+
+class _ConnectionsAPI:
+    def __init__(self, client: 'ThreadSync'):
+        self._client = client
+
+    def create(self, provider: str, **kwargs) -> Connection:
+        data = self._client._request('POST', '/connections', json={'provider': provider, **kwargs})
+        return Connection(**data)
+
+    def get(self, id: str) -> Connection:
+        data = self._client._request('GET', f'/connections/{id}')
+        return Connection(**data)
+
+    def list(self) -> list:
+        data = self._client._request('GET', '/connections')
+        return [Connection(**c) for c in data]
+
+class _SyncAPI:
+    def __init__(self, client: 'ThreadSync'):
+        self._client = client
+
+    def create(self, source: dict, destination: dict, schedule: str = 'realtime') -> Sync:
+        data = self._client._request('POST', '/syncs', json={
+            'source': source, 'destination': destination, 'schedule': schedule
+        })
+        return Sync(**data)
+
+    def get(self, id: str) -> Sync:
+        data = self._client._request('GET', f'/syncs/{id}')
+        return Sync(**data)
+
+class ThreadSync:
+    def __init__(self, bearer_token: str, base_url: str = 'https://api.threadsync.io/v1'):
+        self._http = httpx.Client(
+            base_url=base_url,
+            headers={
+                'Authorization': f'Bearer {bearer_token}',
+                'Content-Type': 'application/json',
+                'User-Agent': 'threadsync-python/0.1.0',
+            },
+        )
+        self.connections = _ConnectionsAPI(self)
+        self.sync = _SyncAPI(self)
+
+    def _request(self, method: str, path: str, **kwargs) -> Any:
+        response = self._http.request(method, path, **kwargs)
+        response.raise_for_status()
+        return response.json()