mirror of
https://github.com/fosrl/olm.git
synced 2026-02-07 21:46:40 +00:00
43
create_test_creds.py
Normal file
43
create_test_creds.py
Normal file
@@ -0,0 +1,43 @@
|
|||||||
|
|
||||||
|
import requests
|
||||||
|
|
||||||
|
def create_olm(base_url, user_token, olm_name, user_id):
|
||||||
|
url = f"{base_url}/api/v1/user/{user_id}/olm"
|
||||||
|
headers = {
|
||||||
|
"Content-Type": "application/json",
|
||||||
|
"Accept": "application/json",
|
||||||
|
"User-Agent": "pangolin-cli",
|
||||||
|
"X-CSRF-Token": "x-csrf-protection",
|
||||||
|
"Cookie": f"p_session_token={user_token}"
|
||||||
|
}
|
||||||
|
payload = {"name": olm_name}
|
||||||
|
response = requests.put(url, json=payload, headers=headers)
|
||||||
|
response.raise_for_status()
|
||||||
|
data = response.json()
|
||||||
|
print(f"Response Data: {data}")
|
||||||
|
|
||||||
|
def create_client(base_url, user_token, client_name):
|
||||||
|
url = f"{base_url}/api/v1/api/clients"
|
||||||
|
headers = {
|
||||||
|
"Content-Type": "application/json",
|
||||||
|
"Accept": "application/json",
|
||||||
|
"User-Agent": "pangolin-cli",
|
||||||
|
"X-CSRF-Token": "x-csrf-protection",
|
||||||
|
"Cookie": f"p_session_token={user_token}"
|
||||||
|
}
|
||||||
|
payload = {"name": client_name}
|
||||||
|
response = requests.post(url, json=payload, headers=headers)
|
||||||
|
response.raise_for_status()
|
||||||
|
data = response.json()
|
||||||
|
print(f"Response Data: {data}")
|
||||||
|
|
||||||
|
if __name__ == "__main__":
|
||||||
|
# Example usage
|
||||||
|
base_url = input("Enter base URL (e.g., http://localhost:3000): ")
|
||||||
|
user_token = input("Enter user token: ")
|
||||||
|
user_id = input("Enter user ID: ")
|
||||||
|
olm_name = input("Enter OLM name: ")
|
||||||
|
client_name = input("Enter client name: ")
|
||||||
|
|
||||||
|
create_olm(base_url, user_token, olm_name, user_id)
|
||||||
|
# client_id = create_client(base_url, user_token, client_name)
|
||||||
11
olm/olm.go
11
olm/olm.go
@@ -742,17 +742,6 @@ func StartTunnel(config TunnelConfig) {
|
|||||||
peerMonitor.HandleFailover(relayData.SiteId, primaryRelay)
|
peerMonitor.HandleFailover(relayData.SiteId, primaryRelay)
|
||||||
})
|
})
|
||||||
|
|
||||||
olm.RegisterHandler("olm/register/no-sites", func(msg websocket.WSMessage) {
|
|
||||||
logger.Info("Received no-sites message - no sites available for connection")
|
|
||||||
|
|
||||||
if stopRegister != nil {
|
|
||||||
stopRegister()
|
|
||||||
stopRegister = nil
|
|
||||||
}
|
|
||||||
|
|
||||||
logger.Info("No sites available - stopped registration and holepunch processes")
|
|
||||||
})
|
|
||||||
|
|
||||||
olm.RegisterHandler("olm/terminate", func(msg websocket.WSMessage) {
|
olm.RegisterHandler("olm/terminate", func(msg websocket.WSMessage) {
|
||||||
logger.Info("Received terminate message")
|
logger.Info("Received terminate message")
|
||||||
Close()
|
Close()
|
||||||
|
|||||||
Reference in New Issue
Block a user