feat: spin up Gitea instance for development and testing
This commit is contained in:
parent
307e9397fc
commit
f8660f9216
3 changed files with 83 additions and 11 deletions
3
.github/workflows/linux.yml
vendored
3
.github/workflows/linux.yml
vendored
|
@ -86,6 +86,9 @@ jobs:
|
||||||
# GIT_HASH: 8e77345f1597e40c2e266cb4e6dee74888918a61 # dummy value
|
# GIT_HASH: 8e77345f1597e40c2e266cb4e6dee74888918a61 # dummy value
|
||||||
# POSTGRES_DATABASE_URL: "${{ env.POSTGRES_DATABASE_URL }}"
|
# POSTGRES_DATABASE_URL: "${{ env.POSTGRES_DATABASE_URL }}"
|
||||||
# SQLITE_DATABASE_URL: "${{ env.SQLITE_DATABASE_URL }}"
|
# SQLITE_DATABASE_URL: "${{ env.SQLITE_DATABASE_URL }}"
|
||||||
|
- name: launch gitea
|
||||||
|
timeout-minutes: 10
|
||||||
|
run: docker-compose -f docker-compose-dev-deps.yml -d up && python ./scripts/gitea.py
|
||||||
|
|
||||||
- name: run tests
|
- name: run tests
|
||||||
timeout-minutes: 40
|
timeout-minutes: 40
|
||||||
|
|
12
Makefile
12
Makefile
|
@ -11,6 +11,14 @@ clean: ## Clean all build artifacts and dependencies
|
||||||
coverage: migrate ## Generate coverage report in HTML format
|
coverage: migrate ## Generate coverage report in HTML format
|
||||||
cargo tarpaulin -t 1200 --out Html --skip-clean --all-features --no-fail-fast #--workspace=database/db-sqlx-postgres,database/db-sqlx-sqlite,.
|
cargo tarpaulin -t 1200 --out Html --skip-clean --all-features --no-fail-fast #--workspace=database/db-sqlx-postgres,database/db-sqlx-sqlite,.
|
||||||
|
|
||||||
|
check: ## Check for syntax errors on all workspaces
|
||||||
|
cargo check
|
||||||
|
# cd db/db-sqlx-sqlite &&\
|
||||||
|
# DATABASE_URL=${SQLITE_DATABASE_URL}\
|
||||||
|
# cargo check
|
||||||
|
# cd db/db-core/ && cargo check
|
||||||
|
# cd db/migrator && cargo check
|
||||||
|
|
||||||
dev-env: ## Download development dependencies
|
dev-env: ## Download development dependencies
|
||||||
cargo fetch
|
cargo fetch
|
||||||
|
|
||||||
|
@ -45,11 +53,11 @@ sqlx-offline-data: ## prepare sqlx offline data
|
||||||
|
|
||||||
test: migrate ## Run tests
|
test: migrate ## Run tests
|
||||||
cargo test --no-fail-fast
|
cargo test --no-fail-fast
|
||||||
|
# cd db/db-sqlx-sqlite &&\
|
||||||
|
# DATABASE_URL=${SQLITE_DATABASE_URL}\
|
||||||
# cd database/db-sqlx-postgres &&\
|
# cd database/db-sqlx-postgres &&\
|
||||||
# DATABASE_URL=${POSTGRES_DATABASE_URL}\
|
# DATABASE_URL=${POSTGRES_DATABASE_URL}\
|
||||||
# cargo test --no-fail-fast
|
# cargo test --no-fail-fast
|
||||||
# cd database/db-sqlx-sqlite &&\
|
|
||||||
# DATABASE_URL=${SQLITE_DATABASE_URL}\
|
|
||||||
|
|
||||||
xml-test-coverage: migrate ## Generate cobertura.xml test coverage
|
xml-test-coverage: migrate ## Generate cobertura.xml test coverage
|
||||||
cargo tarpaulin -t 1200 --out Xml --skip-clean --all-features --no-fail-fast #--workspace=database/db-sqlx-postgres,database/db-sqlx-sqlite,.
|
cargo tarpaulin -t 1200 --out Xml --skip-clean --all-features --no-fail-fast #--workspace=database/db-sqlx-postgres,database/db-sqlx-sqlite,.
|
||||||
|
|
|
@ -1,6 +1,7 @@
|
||||||
from urllib.parse import urlunparse, urlparse
|
from urllib.parse import urlunparse, urlparse
|
||||||
from html.parser import HTMLParser
|
from html.parser import HTMLParser
|
||||||
from time import sleep
|
from time import sleep
|
||||||
|
import random
|
||||||
|
|
||||||
from requests import Session
|
from requests import Session
|
||||||
import requests
|
import requests
|
||||||
|
@ -9,8 +10,8 @@ GITEA_USER = "bot"
|
||||||
GITEA_EMAIL = "bot@example.com"
|
GITEA_EMAIL = "bot@example.com"
|
||||||
GITEA_PASSWORD = "foobarpassword"
|
GITEA_PASSWORD = "foobarpassword"
|
||||||
|
|
||||||
requests.get
|
TOTAL_NUM_REPOS = 100
|
||||||
|
REPOS = []
|
||||||
|
|
||||||
def check_online():
|
def check_online():
|
||||||
count = 0
|
count = 0
|
||||||
|
@ -99,19 +100,24 @@ class HTMLClient:
|
||||||
self.session = Session()
|
self.session = Session()
|
||||||
|
|
||||||
@staticmethod
|
@staticmethod
|
||||||
def get_csrf_token(page: str) -> str:
|
def __get_csrf_token(page: str) -> str:
|
||||||
parser = ParseCSRFGiteaForm()
|
parser = ParseCSRFGiteaForm()
|
||||||
parser.feed(page)
|
parser.feed(page)
|
||||||
csrf = parser.token
|
csrf = parser.token
|
||||||
return csrf
|
return csrf
|
||||||
|
|
||||||
|
def get_csrf_token(self, url: str) -> str:
|
||||||
|
resp = self.session.get(url, allow_redirects=False)
|
||||||
|
if resp.status_code != 200 and resp.status_code != 302:
|
||||||
|
print(resp.status_code, resp.text)
|
||||||
|
raise Exception(f"Can't get csrf token: {resp.status_code}")
|
||||||
|
csrf = self.__get_csrf_token(resp.text)
|
||||||
|
return csrf
|
||||||
|
|
||||||
|
|
||||||
def register(client: HTMLClient):
|
def register(client: HTMLClient):
|
||||||
url = "http://localhost:8080/user/sign_up"
|
url = "http://localhost:8080/user/sign_up"
|
||||||
resp = client.session.get(url, allow_redirects=False)
|
csrf = client.get_csrf_token(url)
|
||||||
if resp.status_code != 200:
|
|
||||||
print(resp.status_code, resp.text)
|
|
||||||
raise Exception(resp.status_code)
|
|
||||||
csrf = client.get_csrf_token(resp.text)
|
|
||||||
payload = {
|
payload = {
|
||||||
"_csrf": csrf,
|
"_csrf": csrf,
|
||||||
"user_name": GITEA_USER,
|
"user_name": GITEA_USER,
|
||||||
|
@ -121,7 +127,58 @@ def register(client: HTMLClient):
|
||||||
}
|
}
|
||||||
resp = client.session.post(url, data=payload, allow_redirects=False)
|
resp = client.session.post(url, data=payload, allow_redirects=False)
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
def login(client: HTMLClient):
|
||||||
|
url = "http://localhost:8080/user/login"
|
||||||
|
csrf = client.get_csrf_token(url)
|
||||||
|
payload = {
|
||||||
|
"_csrf": csrf,
|
||||||
|
"user_name": GITEA_USER,
|
||||||
|
"password": GITEA_PASSWORD,
|
||||||
|
"remember": "on",
|
||||||
|
}
|
||||||
|
resp = client.session.post(url, data=payload, allow_redirects=False)
|
||||||
|
print(f"login {client.session.cookies}")
|
||||||
|
if resp.status_code == 302:
|
||||||
|
print("User logged in")
|
||||||
|
return
|
||||||
|
|
||||||
|
raise Exception(
|
||||||
|
f"[ERROR] Authentication failed. status code {resp.status_code}"
|
||||||
|
)
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
def create_repositories(client: HTMLClient):
|
||||||
|
print("foo")
|
||||||
|
def get_repository_payload(csrf: str, name: str):
|
||||||
|
data = {
|
||||||
|
"_csrf": csrf,
|
||||||
|
"uid": "1",
|
||||||
|
"repo_name": name,
|
||||||
|
"description": f"this repository is named {name}",
|
||||||
|
"repo_template": "",
|
||||||
|
"issue_labels": "",
|
||||||
|
"gitignores": "",
|
||||||
|
"license": "",
|
||||||
|
"readme": "Default",
|
||||||
|
"default_branch": "master",
|
||||||
|
"trust_model": "default"
|
||||||
|
}
|
||||||
|
return data
|
||||||
|
url = "http://localhost:8080/repo/create"
|
||||||
|
for repo in REPOS:
|
||||||
|
csrf = client.get_csrf_token(url)
|
||||||
|
resp = client.session.post(url, data=get_repository_payload(csrf, repo))
|
||||||
|
print(f"Created repository {repo}")
|
||||||
|
if resp.status_code != 302 and resp.status_code != 200:
|
||||||
|
raise Exception(f"Error while creating repository: {repo} {resp.status_code}")
|
||||||
|
|
||||||
|
|
||||||
if __name__ == "__main__":
|
if __name__ == "__main__":
|
||||||
|
for i in range(TOTAL_NUM_REPOS):
|
||||||
|
REPOS.append(f"reopsitory_{i}")
|
||||||
check_online()
|
check_online()
|
||||||
print("Instace online")
|
print("Instace online")
|
||||||
install()
|
install()
|
||||||
|
@ -132,8 +189,12 @@ if __name__ == "__main__":
|
||||||
try:
|
try:
|
||||||
register(client)
|
register(client)
|
||||||
print("User registered")
|
print("User registered")
|
||||||
|
login(client)
|
||||||
|
create_repositories(client)
|
||||||
break
|
break
|
||||||
except:
|
except Exception as e:
|
||||||
|
print(f"Error: {e}")
|
||||||
print(f"Retrying {count} time")
|
print(f"Retrying {count} time")
|
||||||
count += 1
|
count += 1
|
||||||
|
sleep(5)
|
||||||
continue
|
continue
|
||||||
|
|
Loading…
Reference in a new issue