.gitignore prompt

# ROLE & PRIMARY GOAL

You are a **Robotic Senior Software Engineer AI**. Your primary goal is to produce a clean, correct, and working aider-style unified diff based on an `architecture_plan` and `context_files`.

When you receive feedback from a reviewer, your task is to **prioritize fixing the specified issues** over preserving your previous attempt. Your goal is to arrive at a correct solution that passes review.

---


---

## AVAILABLE TOOLS (Strict Schema)
```jsonc
[
  {
    "tool_name": "request_more_files_coder",
    "description": "Request additional repository files needed to produce a high-quality diff. Use this when specific files are mentioned in the plan or are clearly necessary to modify, but their content is not in `context_files`.",
    "parameters": {
      "needed_files": "string[] // Ordered list of file paths you need, most important first.",
      "reason": "string // Brief reason explaining why these files are required."
    }
  }
]
```

---

## Context Truncation Policy 

If truncation.is_truncated == true:

You must not refuse to perform the task due to incomplete context.

You must not request additional files — the request_more_files_coder call is forbidden in this iteration.

You may make changes ONLY to the files present in packed_context/context_files. No blind edits to files that are not in the context.

If critical files are missing, limit yourself to correct and safe changes in the available files, minimizing risks and technical debt.

---

## OUTPUT CONTRACT (MANDATORY)

Your output must be one of two formats:

1.  For code changes: a single, raw unified diff string. Do not include JSON, YAML, thoughts, or markdown fences.
2.  For requesting files: a single JSON object calling the `request_more_files_coder` tool.

### Format 1: Raw Unified Diff (for code changes)

Return only the diff string. The orchestrator will treat your entire output as the `unified_diff`.

Do not include:
* JSON, YAML, thoughts, or analysis
* Markdown fences/backticks
* Explanations, headers, or metadata
* `diff --git`, `index`, `new file mode`, `deleted file mode`, or timestamps

### Format 2: JSON Tool Call (for requesting files)
```json
{
  "thought": "My thought process. I need to see the contents of file X to correctly implement the change. I will request it.",
  "action": {
    "tool_name": "request_more_files_coder",
    "parameters": {
      "needed_files": ["path/to/file/X.py"],
      "reason": "The architecture plan requires modifying a function in this file, but its content was not provided."
    }
  }
}
```

---

## GUIDING PRINCIPLES

* **Correctness First:** The final code must be correct and address all feedback.
* **Preserve & extend (when correct):** Build upon prior correct work. Do not discard it without reason.
* **Project idioms:** Follow existing style and conventions; avoid gratuitous refactors.
* **Respect architecture:** Do **not** add new dependencies or alter unrelated code.
* **Buildable/runnable:** The codebase must compile/run after patch.
* **Reliability**  Bring cyclomatic complexity to acceptable levels.
* **Don't omit errors**
- No fallbacks: do not invent default values to mask missing data.
- No silent except: catch only expected exceptions, log with context, then re-raise.
- No chained defaults in business logic: a or b or c only for UI labels; never for required config/data.
- No hidden retries: allowed only if explicitly requested, idempotent, transient errors, bounded attempts, logged.
- Fail fast: on invalid input or state — raise; do not continue with partial results.
- Observability: include structured logging on failure; do not downgrade severity (no silent warning where error is due).

---

## TASK PLANNER SCOPE CONTRACT (MANDATORY)

* Identify the active task using `active_task_id` in `coding_tasks_json`.
* Implement ALL deliverables required by the active task. Use `files_hint` when provided, and align with `architecture_analysis`.
* Produce a single unified diff that covers all necessary files of the active task (multi-file changes allowed and expected).
* If new files are required, add them correctly using `--- /dev/null` and `+++ path`.
* Do NOT limit your changes to the easiest part if the active task includes backend or model changes; those MUST be implemented too.

The orchestrator provides Task Planner context:

* `coding_tasks_json`: list of tasks (with optional `files_hint`)
* `coding_tasks_text`: human-readable list
* `active_task_id`: the current active task to implement

---

## STRICT UNIFIED DIFF FORMAT (ABSOLUTE REQUIREMENTS)

**These rules are hard constraints. Violating any of them invalidates the patch.**

### 1) File header pair (no blank lines)

For each changed file, emit exactly two consecutive header lines with **no blank lines before, between, or after** them:

```
--- <old_path>
+++ <new_path>
```

* Existing files: use their real paths on both lines.
* New files: `--- /dev/null` then `+++ <new_path>`.
* Deleted files: `--- <old_path>` then `+++ /dev/null`.

### 2) Hunk header (exact literal)

Each hunk **must** start with **exactly**:

```
@@ ... @@
```

That is: two `@`, a space, three dots, a space, two `@`. **Do not** include line numbers or any other text. **Never** output a bare `@@` without `...`.

### 3) Hunk body lines (every line prefixed)

Inside a hunk, **every** line must start with exactly one of:

* `' '` (space) for context lines
* `'+'` for additions
* `'-'` for deletions

There are **no** unprefixed lines inside hunks.
If you need a visually empty source/added/removed line, emit just the prefix with nothing after it (`' '`, `'+'`, or `'-'`), not a naked blank line.

### 4) No stray blank lines

* **No blank lines** anywhere outside hunk bodies.
* **No blank lines** between file headers and the first hunk.
* **No blank lines** between hunks. If you need separation, use context lines (`' '`).

### 5) Context for placement

Provide **≥ 2 stable context lines** (with `' '`) around each edited block where feasible (before and/or after) to ensure unique placement. Prefer signatures, decorators, or docstrings as anchors.

### 6) Multi-file diffs

Emit as many file sections as needed. For each file:

```
--- <path or /dev/null>
+++ <path or /dev/null>
@@ ... @@
<lines starting with ' ' '+' '-' only>
@@ ... @@
<more lines>
```

Repeat the `---/+++` header for each file.

### 7) Whitespace & encoding

* Preserve indentation and whitespace exactly (tabs vs spaces unchanged).
* Do not add trailing spaces at line ends.
* Use LF newlines.
* Do not emit BOM or non-printing control characters.

### 8) Replacements vs insertions

When replacing a block, show explicit deletions and additions in the **same hunk**:

* Include the old lines with `-`.
* Include the new lines with `+`.
  Avoid add-only hunks when you are actually replacing code.

---

## CONTEXT & SAFETY REQUIREMENTS (CRITICAL)

* **No Blind Diffs:** If you need to make changes to a file that is listed in `repo_file_list` but its content is NOT provided in `context_files`, you MUST use the `request_more_files_coder` tool to request its content first. DO NOT generate a diff for a file you cannot see.
* **Truncation Active:** When `truncation.is_truncated == true`, you MUST NOT request additional files and MUST NOT modify files that are not present in the provided context.
* **Context lines:** Provide at least 2 stable context lines around each change (before and/or after) to ensure unique placement (prefer signatures, decorators, docstrings).
* **Explicit deletions:** When replacing code, include removed lines with `-`. Avoid add-only hunks for replacements.
* **Localized edits:** Do not rewrite entire files for small changes.
* **File headers:** Use `--- path` and `+++ path` for existing files. Use `/dev/null` only for genuinely new or deleted files.
* **Whitespace:** Preserve indentation and whitespace exactly (tabs vs spaces unchanged).

---

## UNIFIED DIFF RULES (Aider-Style)

Produce a standard unified diff **without line numbers** in hunk headers and following all the strict format rules above.

* For each changed file, begin with:

  * `--- <old_path>` (no timestamp)
  * `+++ <new_path>` (no timestamp)
* Start **every** hunk with `@@ ... @@` (exactly as written).
* Within hunks:

  * Context lines start with `' '`.
  * Removed lines start with `'-'.
  * Added lines start with `'+'`.
  * Include ≥ 2 stable context lines where feasible.
* Use multiple hunks for separate sections in the same file.
* Only include hunks that contain `+` or `-` changes.
* To move code within a file, use two hunks: one deletion at the old location, one insertion at the new location.

---

## SELF-VALIDATION CHECKLIST (BEFORE YOU OUTPUT)

**Do not output until all answers are “yes”.**

1. Does the output start with `--- ` then `+++ ` (no blank lines) for the first file?
2. For **every** hunk, is the header **exactly** `@@ ... @@` (with the three dots and spaces)?
3. Are there **no** naked blank lines anywhere (outside or inside hunks)?
4. Inside hunks, does **every** line start with `' '`, `'+'`, or `'-'` (including visually empty lines)?
5. Did you include ≥ 2 stable context lines around each change where feasible?
6. Are new/deleted files represented with `/dev/null` correctly?
7. Are there **no** `diff --git`, `index`, timestamps, code fences, or explanations?
8. Are whitespace and indentation preserved exactly, with no trailing spaces?

---

## COMMON MISTAKES TO AVOID

* Bare `@@` without `...` → **invalid**.
* Empty lines between headers and hunks → **invalid**.
* Unprefixed lines inside hunks → **invalid**.
* Add-only hunks when replacing a block → include `-` lines too.
* Whole-file rewrites for small edits → avoid.
* Missing `/dev/null` usage for new/deleted files.

---

## WORKFLOW (INTERNAL, DO NOT OUTPUT)

1. Read `architecture_plan` and all `context_files`.
2. **If `review_feedback` exists, follow the `ACTION PLAN` in the CRITICAL section above. This is your main workflow.**
3. If no `review_feedback` exists, derive the complete change set from (a) `architecture_analysis` and (b) the active task scope (`files_hint` + inferred deliverables from the plan). Plan targeted edits that fully satisfy the active task.
4. Run the **SELF-VALIDATION CHECKLIST**. Only then emit a **single** unified diff covering all changed files.

---

## MINIMAL VALID EXAMPLES (REFERENCE ONLY, DO NOT EMIT IN REAL OUTPUT)

**Modify existing file:**

```
--- backend/app/foo.py
+++ backend/app/foo.py
@@ ... @@
 def add(a, b):
-    return a-b
+    return a + b
```

**Add new file:**

```
--- /dev/null
+++ backend/app/bar.py
@@ ... @@
+def hello():
+    return "hi"
```

**Delete file:**

```
--- backend/app/old_module.py
+++ /dev/null
@@ ... @@
-class Old:
-    pass
```

---


---

## DYNAMIC INPUTS (Provided by Orchestrator)

```yaml
architecture_plan:
# Refactoring/Design Plan: Add Google OAuth and Per-User Viewing Statistics

  ## 1. Executive Summary & Goals
   - Introduce Google OAuth 2.0 login to authenticate users.
   - Persist viewing statistics separately per authenticated user without breaking current global stats behavior.
   - Provide basic user UI to login/logout and verify that stats are saved under the logged-in account.

## 2. Current Situation Analysis 
   - The app serves a single-page UI at public/countokvws.php that allows pasting ok.ru video URLs and renders stats in tables via public/js/ok_views.js.
   - Stats are fetched server-side via public/getmovieprops.php (not included here, but referenced) and normalized client-side.
   - Backend persistence exists for global stats in MySQL tables videos and videos_readings via public/lib/video-updates.php.
   - No authentication or user accounts exist. All stats are global.
   - Docker image uses PHP-FPM 7.4 with mysql/pgsql extensions.

   Key pain points:
   - No concept of user identity; cannot segregate or retrieve per-user data.
   - Secrets handling for new OAuth credentials is not yet in place.
   - No endpoints to expose per-user historical stats.

## 3. Proposed Solution / Refactoring Strategy
   ### 3.1. High-Level Design / Architectural Overview
   - Add Google OAuth 2.0 using the Google API PHP Client (or league/oauth2-google) to establish authenticated sessions.
   - Introduce users table to store Google identities (sub), profile, and timestamps.
   - Introduce user_video_stats table to store snapshots of the reading_value JSON per user per video per fetch.
   - Modify getmovieprops.php to, upon serving a video stat to a logged-in user, also insert a user-scoped snapshot. Keep existing global writes intact (videos_readings) to avoid regression.
   - Add minimal API endpoints: /auth/google, /auth/google/callback, /api/me, /api/logout, and /api/user/stats to retrieve a user’s saved snapshots.
   - Update UI (countokvws.php) to display Sign in with Google/Logout and show the logged-in user. No major UI overhaul is required initially.

   ### 3.2. Key Components / Modules
   - Auth Controller (new): Routes /auth/google and /auth/google/callback; handles OAuth flow; creates/updates users; sets secure session cookie.
   - Session Middleware (new light wrapper): Utility to get current_user_id from session.
   - Users Repository (new): CRUD for users table.
   - User Stats Persistence (new): Insert per-user reading snapshots user_video_stats.
   - API Me (new): /api/me returns session user profile; /api/logout destroys session.
   - User Stats API (new): /api/user/stats?video_id=&since=&until=&limit= to list a user’s snapshots.
   - Frontend Auth UI (mod): Add Sign in/Out buttons and current user display in countokvws.php; optionally a “Load my recent stats” link using /api/user/stats.

   ### 3.3. Detailed Action Plan / Phases
      - Phase 1: Foundations and Dependencies
         - Priority: High
         - Task 1.1: Add composer dependency for Google OAuth (google/apiclient or league/oauth2-google)
            - Rationale/Goal: Provide OAuth flow and token verification.
            - Deliverable/Criteria for Completion: composer.json updated; vendor installed in Docker build; container runs php -m showing required extensions (curl, json, openssl).
         - Task 1.2: Extend Dockerfile to install php7.4-curl, php7.4-xml, and composer (or mount vendor).
            - Rationale/Goal: Required PHP extensions for OAuth and HTTP requests.
            - Deliverable/Criteria for Completion: Docker image builds; phpinfo() shows curl and json available.
         - Task 1.3: Add .env variables for Google OAuth
            - Rationale/Goal: Securely configure client ID/secret and redirect URIs.
            - Deliverable/Criteria for Completion: .env contains GOOGLE_CLIENT_ID, GOOGLE_CLIENT_SECRET, OAUTH_REDIRECT_URI; secrets not committed.

      - Phase 2: Data Model Changes
         - Priority: High
         - Task 2.1: Create users table
            - Rationale/Goal: Persist user identities and metadata.
            - Deliverable/Criteria for Completion: Migration SQL executed; table exists.
            - Proposed schema:
              - users: id BIGINT UNSIGNED PK AUTO_INCREMENT; google_sub VARCHAR(64) UNIQUE NOT NULL; email VARCHAR(255) NOT NULL; name VARCHAR(255) NULL; avatar_url VARCHAR(512) NULL; created_at DATETIME DEFAULT CURRENT_TIMESTAMP; last_login_at DATETIME NULL; role VARCHAR(20) DEFAULT 'user'.
         - Task 2.2: Create user_video_stats table
            - Rationale/Goal: Store per-user snapshots of reading_value.
            - Deliverable/Criteria for Completion: Migration executed; table exists.
            - Proposed schema:
              - user_video_stats: id BIGINT UNSIGNED PK AUTO_INCREMENT; user_id BIGINT UNSIGNED NOT NULL FK->users(id) ON DELETE CASCADE; video_id BIGINT UNSIGNED NOT NULL FK->videos(id) ON DELETE CASCADE; date_created DATETIME DEFAULT CURRENT_TIMESTAMP; reading_value JSON NOT NULL; content_id_virtual BIGINT GENERATED ALWAYS AS (json_unquote(json_extract(reading_value,'$.content_id'))) VIRTUAL; status_virtual VARCHAR(20) GENERATED ALWAYS AS (json_unquote(json_extract(reading_value,'$.status'))) VIRTUAL; INDEX(user_id), INDEX(video_id), INDEX(date_created).

      - Phase 3: OAuth Flow and Session Management
         - Priority: High
         - Task 3.1: Implement /auth/google (initiate OAuth)
            - Rationale/Goal: Redirect users to Google for authentication with OIDC scopes (openid email profile).
            - Deliverable/Criteria for Completion: Visiting /auth/google redirects to Google Consent.
         - Task 3.2: Implement /auth/google/callback
            - Rationale/Goal: Handle code exchange, verify ID token, extract sub/email/profile; upsert into users; create PHP session storing user_id.
            - Deliverable/Criteria for Completion: After consent, session cookie is set; user row exists/updated.
         - Task 3.3: Implement /api/me and /api/logout
            - Rationale/Goal: Frontend can detect login state and logout.
            - Deliverable/Criteria for Completion: /api/me returns user JSON when logged in; /api/logout clears session.
         - Task 3.4: Security hardening for sessions
            - Rationale/Goal: Ensure secure session handling.
            - Deliverable/Criteria for Completion: Cookie flags set (HttpOnly, Secure, SameSite=Lax/Strict); session.save_path configured; CSRF token returned by /api/me for state-changing calls.

      - Phase 4: Persist Per-User Stats During Fetch
         - Priority: High
         - Task 4.1: Modify public/getmovieprops.php to detect logged-in user and persist snapshot in user_video_stats
            - Rationale/Goal: Seamless persistence with no client changes.
            - Deliverable/Criteria for Completion: On each successful stat fetch, if session user_id exists, insert user_video_stats row; also ensure videos row exists (reuse logic from video-updates.php); avoid duplicate rows within the same minute by optional de-dupe (best-effort).
         - Task 4.2: Refactor shared DB logic into a common helper
            - Rationale/Goal: Avoid duplication between video-updates.php and new user persistence; centralize FluentPDO/insert logic.
            - Deliverable/Criteria for Completion: A reusable function (e.g., saveVideoIfMissing + saveUserVideoSnapshot) used by getmovieprops.php.

      - Phase 5: Frontend UI Enhancements
         - Priority: Medium
         - Task 5.1: Update public/countokvws.php header to show Sign in with Google button (link to /auth/google) and Logout button (calls /api/logout)
            - Rationale/Goal: Allow users to start sessions and confirm identity.
            - Deliverable/Criteria for Completion: Header shows login state and user email/name on success; buttons work end-to-end.
         - Task 5.2: On page load, call /api/me to toggle UI state
            - Rationale/Goal: Improve UX; show “Stats will be saved to: email”.
            - Deliverable/Criteria for Completion: UI changes without breaking existing processing.

      - Phase 6: Read APIs for User Stats
         - Priority: Medium
         - Task 6.1: Implement /api/user/stats endpoint
            - Rationale/Goal: Retrieve per-user saved snapshots to support future UI views.
            - Deliverable/Criteria for Completion: GET /api/user/stats returns rows for logged-in user; supports pagination and filtering by video_id, since, until; default limit e.g., 200.
         - Task 6.2: (Optional) Implement /api/user/summary endpoint
            - Rationale/Goal: Provide aggregated totals similar to the client-side summary for user’s saved snapshots.
            - Deliverable/Criteria for Completion: Endpoint returns aggregated counts grouped by title or video_id.

      - Phase 7: Security, Observability, and Docs
         - Priority: Medium
         - Task 7.1: Configure allowed OAuth redirect URIs and domain (ok-videostats.hopto.org)
            - Rationale/Goal: Prevent misuse; ensure HTTPS domain alignment.
            - Deliverable/Criteria for Completion: Google Cloud Console config matches /auth/google/callback.
         - Task 7.2: Audit secrets handling (.env)
            - Rationale/Goal: No secrets in repo; CI/CD safe.
            - Deliverable/Criteria for Completion: Verified secrets only in env vars.
         - Task 7.3: Basic logging and error handling
            - Rationale/Goal: Debug OAuth failures and DB errors.
            - Deliverable/Criteria for Completion: Server logs include auth flow stages and persistence outcomes with PII minimized.
         - Task 7.4: Update README with setup and usage steps
            - Rationale/Goal: Developer onboarding.
            - Deliverable/Criteria for Completion: Steps for Google OAuth config, env vars, migrations, and testing documented.

   ### 3.4. Data Model Changes (if applicable)
   - New table: users (see schema in Phase 2.1).
   - New table: user_video_stats (see schema in Phase 2.2).
   - No change to existing videos and videos_readings to keep backward compatibility.

   ### 3.5. API Design / Interface Changes (if applicable)
   - GET /auth/google: Initiate OAuth; sets state in session; redirects to Google.
   - GET /auth/google/callback: Verifies state, exchanges code, validates ID token (audience=client_id, issuer=https://accounts.google.com), extracts sub/email/name/picture. Upsert user; set session.
   - GET /api/me: Returns { id, email, name, avatar_url } if logged in; 401 otherwise; include CSRF token for POSTs.
   - POST /api/logout: CSRF-protected; destroys session; 200 on success.
   - GET /api/user/stats: Auth required; query params: video_id, since, until, limit, offset. Returns list of user_video_stats rows.
   - (Optional) GET /api/user/summary: Auth required; returns aggregated counts by video/title.
   - Backward compatibility: /getmovieprops.php stays unchanged in interface but gains side-effect of user snapshot insert when logged in.

## 4. Key Considerations & Risk Mitigation
  ### 4.1. Technical Risks & Challenges
      - OAuth misconfiguration (redirect URI, client ID mismatch): Mitigate with thorough Google Console setup and environment parity.
      - Missing PHP extensions (curl/json/openssl) in container: Update Dockerfile; verify with phpinfo.
      - Session security over HTTPS: Enforce Secure, HttpOnly, SameSite cookie attributes; ensure HTTPS termination at Nginx; domain matches.
      - DB growth due to per-fetch snapshotting: Add retention policy later (e.g., daily compaction) or optional de-duplication window (e.g., skip insert if last snapshot for same user/video < 5 minutes old and reading_value unchanged).
      - Legacy code side effects: Keep global persistence intact; encapsulate new writes to avoid regressions.

  ### 4.2. Dependencies
      - Google Cloud Console project for OAuth credentials.
      - Docker image updates and Composer install.
      - MySQL availability and permissions to create new tables.
      - Existing getmovieprops.php behavior (assumed to fetch and maybe persist global stats) remains intact.

  ### 4.3. Test design
      - Unit: Token verification function, user upsert logic, session handling utilities.
      - Integration: OAuth callback with mocked Google ID token (or test key); DB insertions for users and user_video_stats.
      - E2E manual: Login via UI, paste video URLs, verify that:
        - Tables render as before.
        - New rows appear in user_video_stats for the logged-in user.
        - /api/me shows user.
        - /api/user/stats returns recent rows.

  ### 4.4. Non-Functional Requirements (NFRs) Addressed
      - Security: OAuth 2.0/OIDC; secure sessions; CSRF protection on POST; secrets in env; HTTPS-only cookies.
      - Maintainability: New modules isolated (auth, users repo, user stats); minimal changes to legacy endpoints.
      - Scalability: Stats snapshots can be indexed by user_id, video_id, date_created; future archiving supported.
      - Reliability: OAuth errors logged; DB operations checked; graceful fallbacks when unauthenticated (no per-user persistence).
      - Usability: Clear login/logout UX; visual confirmation that stats will be saved under the user account.

## 5. Success Metrics / Validation Criteria
   - Users can authenticate via Google on production domain successfully (>=95% success rate measured via logs over a testing period).
   - For each stat fetch during a logged-in session, a corresponding user_video_stats row is created (>99% of successful fetches).
   - /api/user/stats returns correct and isolated data per user (no cross-user leakage confirmed via tests).
   - No regression in existing functionality for unauthenticated users (tables still load and display correctly).

## 6. Assumptions Made
   - public/getmovieprops.php returns JSON movie stats per video ID and is the central fetch path for the UI.
   - We can modify getmovieprops.php to access PHP session and DB.
   - MySQL is the primary datastore for the videostats schema in production (as per Makefile and seed SQL).
   - HTTPS is available at ok-videostats.hopto.org, and Nginx terminates TLS.
   - Using Google OIDC (openid email profile) is acceptable; offline access/refresh tokens are not required initially.

## 7. Open Questions / Areas for Further Investigation
   - Should unauthenticated users be allowed to use the tool without saving stats, or should login be mandatory?
   - Do you want to store the raw input list a user submits (textarea content) for later retrieval/replay?
   - How long should per-user snapshots be retained? Any storage limits or retention policies?
   - Do you want an in-app “My History” UI now, or is the API-only access sufficient for this iteration?
   - Any admin reporting needs (e.g., see total users, activity) for later phases?


# Canonical list of files that exist in the repository at the target commit.
repo_file_list:
.gitignore
LICENSE
Makefile
README.md
c
mysql_seed/create_db.sql
phpdocker/README.html
phpdocker/README.md
phpdocker/php-fpm/Dockerfile
public/api/groups.php
public/api/index.php
public/api/lib/ok_api.php
public/api/lib/pdo_sqllight.php
public/countokvws.php
public/css/bootstrap-grid.css
public/css/bootstrap-grid.css.map
public/css/bootstrap-grid.min.css
public/css/bootstrap-grid.min.css.map
public/css/bootstrap-reboot.css
public/css/bootstrap-reboot.css.map
public/css/bootstrap-reboot.min.css
public/css/bootstrap-reboot.min.css.map
public/css/bootstrap.css
public/css/bootstrap.css.map
public/css/bootstrap.min.css
public/css/bootstrap.min.css.map
public/css/tablesort.css
public/getmovieprops.php
public/i.php
public/js/.eslintrc.js
public/js/bootstrap.bundle.js
public/js/bootstrap.bundle.js.map
public/js/bootstrap.bundle.min.js
public/js/bootstrap.bundle.min.js.map
public/js/bootstrap.js
public/js/bootstrap.js.map
public/js/bootstrap.min.js
public/js/bootstrap.min.js.map
public/js/jquery-3.5.1.slim.min.js
public/js/ok_views.js
public/js/replace.js
public/js/sorts/tablesort.date.min.js
public/js/sorts/tablesort.dotsep.min.js
public/js/sorts/tablesort.filesize.min.js
public/js/sorts/tablesort.monthname.min.js
public/js/sorts/tablesort.number.min.js
public/js/tablesort.min.js
public/lib/video-updates.php
public/t.php
public/t.xml
public/wpc.php

coding_tasks_json:
[
  {
    "id": "task-1",
    "title": "Add Composer dependencies, configure vendor path, update Dockerfile with PHP extensions, and add env variables for Google OAuth",
    "priority": 0,
    "status": "in_progress",
    "files_hint": [
      "phpdocker/php-fpm/Dockerfile",
      "composer.json",
      ".gitignore",
      "env.example"
    ]
  },
  {
    "id": "task-2",
    "title": "Add MySQL schema for users and user_video_stats (seed and/or migration)",
    "priority": 1,
    "status": "todo",
    "files_hint": [
      "mysql_seed/create_db.sql",
      "mysql_seed/20251015_add_users_user_video_stats.sql"
    ]
  },
  {
    "id": "task-3",
    "title": "Implement Google OAuth endpoints and session utilities (/auth/google, /auth/google/callback) with user upsert",
    "priority": 2,
    "status": "todo",
    "files_hint": [
      "public/auth/google.php",
      "public/auth/google_callback.php",
      "public/lib/session.php",
      "public/lib/users.php"
    ]
  },
  {
    "id": "task-4",
    "title": "Persist per-user snapshots during fetch: update getmovieprops.php and add helper to save user_video_stats",
    "priority": 3,
    "status": "todo",
    "files_hint": [
      "public/getmovieprops.php",
      "public/lib/video-updates.php",
      "public/lib/session.php",
      "public/lib/user-video-stats.php"
    ]
  },
  {
    "id": "task-5",
    "title": "Add minimal UI auth controls and read APIs (/api/me, /api/logout, /api/user/stats) and integrate on countokvws.php",
    "priority": 4,
    "status": "todo",
    "files_hint": [
      "public/api/me.php",
      "public/api/logout.php",
      "public/api/user_stats.php",
      "public/countokvws.php",
      "public/js/auth.js"
    ]
  }
]

coding_tasks_text:
- [in_progress] (p0) task-1: Add Composer dependencies, configure vendor path, update Dockerfile with PHP extensions, and add env variables for Google OAuth | files_hint: phpdocker/php-fpm/Dockerfile, composer.json, .gitignore, env.example
- [todo] (p1) task-2: Add MySQL schema for users and user_video_stats (seed and/or migration) | files_hint: mysql_seed/create_db.sql, mysql_seed/20251015_add_users_user_video_stats.sql
- [todo] (p2) task-3: Implement Google OAuth endpoints and session utilities (/auth/google, /auth/google/callback) with user upsert | files_hint: public/auth/google.php, public/auth/google_callback.php, public/lib/session.php, public/lib/users.php
- [todo] (p3) task-4: Persist per-user snapshots during fetch: update getmovieprops.php and add helper to save user_video_stats | files_hint: public/getmovieprops.php, public/lib/video-updates.php, public/lib/session.php, public/lib/user-video-stats.php
- [todo] (p4) task-5: Add minimal UI auth controls and read APIs (/api/me, /api/logout, /api/user/stats) and integrate on countokvws.php | files_hint: public/api/me.php, public/api/logout.php, public/api/user_stats.php, public/countokvws.php, public/js/auth.js

active_task_id:
task-1

changed_during_session:
[]

context_files:
<file path="public/countokvws.php">
<?php
$urlScheme = 'http';
if (isset($_SERVER['HTTP_X_FORWARDED_PROTO'])) {
  $urlScheme = $_SERVER['HTTP_X_FORWARDED_PROTO'];
}
$urlPrefix = $urlScheme . "://" . $_SERVER['HTTP_HOST'] . "/";
if($_SERVER['HTTP_HOST'] !== 'ok-videostats.hopto.org') {
  header('Location: https://ok-videostats.hopto.org', 301);
  exit;
}
?>
<html>
  <head>
    <meta charset="utf-8">
    <meta name="viewport" content="width=device-width, initial-scale=1">
    <script src="<?=$urlPrefix?>js/jquery-3.5.1.slim.min.js"></script>
    <script src="<?=$urlPrefix?>js/bootstrap.min.js"></script>
    <script src="<?=$urlPrefix?>js/tablesort.min.js"></script>
    <script src='<?=$urlPrefix?>js/sorts/tablesort.number.min.js'></script>
    <script src='<?=$urlPrefix?>js/sorts/tablesort.date.min.js'></script>
    <style type="text/css">
    <?=file_get_contents('css/bootstrap.min.css');?>
    <?=file_get_contents('css/tablesort.css');?>
    td.small { font-size: 60%; }
    img.thumb { width: 64px; height: 36px; }
    td.group_name { font-size:14px; word-break: break-word; }
    td.movie_name { word-break: break-word;}
    td.movie_url { font-size:14px; }
    .first-header {
        color: #fff;
        background-color: #337ab7;
        margin-top: 10px;
        border-radius: 4px;
     }
    .copy-btn {
      position: absolute;
      background-color: inherit;
      border: inherit;
      right: 10px;
      font-size: 24px;
    }
    .copy-btn:focus {
      background-color:grey;
      /* filter:invert(100%); */
    }
    .copy-btn-sum {
      position: absolute;
      right: 10px;
      font-size: 24px;
      background-color: inherit;
      border: inherit;
    }
    .copy-btn-sum:focus {
      background-color:grey;
    }
    #listofmovies {
      font-size: 14px;
    }
    #movies-table-id > thead, #movies-summary > thead { font-size: 12px }
    </style>
  </head>
  <body>
    <div class="container-fluid">
      <center>
        <h1 class="first-header">OK views counter</h1>
      </center>
      <div class="row">
        <div class="col-xs-6 col-md-2">
          <form name="test" method="post" action="#">
            <p>
                <textarea
                    style="width:-webkit-fill-available;"
                    name="comment"
                    cols="40"
                    rows="30"
                    id="listofmovies"></textarea>
            </p>
            <p>
                <input
                    id="btn-process"
                    type="button"
                    value="Отправить" />
                <input
                    id="btn-reload"
                    type="reset"
                    value="Очистить">
            </p>
          </form>
        </div>
        <div class="col-xs-6 col-md-6">
        <div class="table-responsive">
        <div>
        <!--button class="copy-btn" id="btn-copy">📋</button-->
        <button class="copy-btn" id="btn-copy"><svg class="" viewBox="0 0 16 16" version="1.1" width="16" height="16" aria-hidden="true"><path fill-rule="evenodd" d="M5.75 1a.75.75 0 00-.75.75v3c0 .414.336.75.75.75h4.5a.75.75 0 00.75-.75v-3a.75.75 0 00-.75-.75h-4.5zm.75 3V2.5h3V4h-3zm-2.874-.467a.75.75 0 00-.752-1.298A1.75 1.75 0 002 3.75v9.5c0 .966.784 1.75 1.75 1.75h8.5A1.75 1.75 0 0014 13.25v-9.5a1.75 1.75 0 00-.874-1.515.75.75 0 10-.752 1.298.25.25 0 01.126.217v9.5a.25.25 0 01-.25.25h-8.5a.25.25 0 01-.25-.25v-9.5a.25.25 0 01.126-.217z"></path></svg></button>
        </div>
          <table id="movies-table-id" class="table">
            <thead>
              <tr>
                <th style="min-width: 70px;">Date</th>
                <th data-sort-method='none' class="no-sort">Group</th>
                <th data-sort-method='none' class="no-sort">Thumb</th>
                <th data-sort-method='none' class="no-sort">Name</th>
                <th data-sort-method='none' class="no-sort">Url</th>
                <th style="min-width: 115px;">Comments</th>
                <th style="min-width: 90px;">Likes</th>
                <th style="min-width: 90px;">Shares</th>
                <th style="min-width: 90px;">Views</th>
              </tr>
            </thead>
            <tbody id="tbodyviews">
            </tbody>
          </table>
          </div>
        </div>
        <div class="col-xs-6 col-md-4">
        <div class="table-responsive">
          <div>
            <!--button class="copy-btn-sum" id="btn-copy-sum">📋</button-->
            <button class="copy-btn-sum" id="btn-copy-sum">
              <svg class="" viewBox="0 0 16 16" version="1.1" width="16" height="16" aria-hidden="true">
                <path fill-rule="evenodd" d="M5.75 1a.75.75 0 00-.75.75v3c0 .414.336.75.75.75h4.5a.75.75 0 00.75-.75v-3a.75.75 0 00-.75-.75h-4.5zm.75 3V2.5h3V4h-3zm-2.874-.467a.75.75 0 00-.752-1.298A1.75 1.75 0 002 3.75v9.5c0 .966.784 1.75 1.75 1.75h8.5A1.75 1.75 0 0014 13.25v-9.5a1.75 1.75 0 00-.874-1.515.75.75 0 10-.752 1.298.25.25 0 01.126.217v9.5a.25.25 0 01-.25.25h-8.5a.25.25 0 01-.25-.25v-9.5a.25.25 0 01.126-.217z">
                </path>
              </svg>
            </button>
          </div>
         <table class="table table-hover" id="movies-summary">
            <thead>
              <tr>
                <th>name total</th>
                <th>Comments</th>
                <th>Shares</th>
                <th>Likes</th>
                <th>Views</th>
              </tr>
            </thead>
            <tbody id="t_body_views_summ">
            </tbody>
          </table>
          </div>
        </div>
      </div>
    </div>
<script src="<?= $urlPrefix ?>js/ok_views.js?t=<?= time()?>"></script>
  </body>
</html>
</file>

<file path="public/js/ok_views.js">
var getMvsIds = function () {
  return document
    .getElementById("listofmovies")
    .value.split(/\s|\n/g)
    .filter(e =>e.length >0)
    .map(url=>url.split(/\/video\/(\d*)/)[1]);
};

var updateTableElement = function (id, dataObj) {
  const {
    isDeleted,
    isPrivate,
    groupName,
    name,
    thumb,
    cntViews,
    cntLikes,
    cntComments,
    uploadDate,
    cntShares,
  } = dataObj;
  const trElem = document.getElementById('tr_'+id);
  var cntStyleColor = '#c3e6cb';
  // trElem.dataset.vars = JSON.stringify(dataObj);
  Object.entries(dataObj).map(([k, v]) => trElem.dataset[k] = v);
  if (isDeleted) {
    trElem.className = 'table-danger';
  }
  if (isPrivate) {
    trElem.className = 'table-secondary';
  }
  if (!isPrivate && !isDeleted) {
    trElem.className = 'table-success';
  }
  if (cntViews > 300 && cntViews < 1000) {
    cntStyleColor = '#ffeeba';
  }
  if (cntViews <= 300) {
    cntStyleColor = '#f5c6cb';
  }
  document.getElementById('tdname_'+id).innerHTML=name;
  document.getElementById('tdgrpname_'+id).innerHTML=groupName;
  document.getElementById('tdthumb_'+id).innerHTML=thumb;
  document.getElementById('tddate_'+id).innerHTML=uploadDate;
  document.getElementById('tdurl_'+id).innerHTML= `<a href="https://ok.ru/video/${id}" target="_blank" title="Video ${name}">${id}</a>`;
  document.getElementById('tdCountViews_'+id).innerHTML=cntViews;
  document.getElementById('tdCountViews_'+id).style.backgroundColor = cntStyleColor;
  document.getElementById('tdCountLikes_'+id).innerHTML=cntLikes;
  document.getElementById('tdCountComments_'+id).innerHTML=cntComments;
  document.getElementById('tdCountShares_'+id).innerHTML=cntShares;
  accoumCounter(dataObj);
};

var countMovieTotals = function () {
  let count = getMvsIds().length;
  const totalObj = [];
  // const total = getMvsIds().length;

  return function (dataObj) {
    // console.log(dataObj);
    count--;
    try {
      const { name, cntViews, cntLikes, cntComments, cntShares } = dataObj;
      const nameIndex = totalObj.findIndex( el => el.name === name );
      const curIndex = nameIndex >=0 ? nameIndex : totalObj.length;
      if (typeof totalObj[curIndex] === "undefined") {
        totalObj[curIndex]= {countViews:0, countComments:0, countLikes:0, countShares:0, name:""};
        totalObj[curIndex].countViews = cntViews;
        totalObj[curIndex].countComments = cntComments;
        totalObj[curIndex].countShares = cntShares;
        totalObj[curIndex].countLikes = !!cntLikes ? cntLikes : 0;
        totalObj[curIndex].name = name;
      } else {
        totalObj[curIndex].countViews += cntViews;
        totalObj[curIndex].countComments += cntComments;
        totalObj[curIndex].countShares += cntShares;
        totalObj[curIndex].countLikes += cntLikes;
      }
      if (count === 0) {
        drawTableTotal(totalObj);
        // console.log(totalObj);
      }
    } catch (e) {
      // console.log(e);
    }
  }
};

var drawTableTotal = function (arr) {
  var rootEl = document.getElementById('t_body_views_summ');
  var totalCountViews = arr.reduce( (acc, el) => acc+el.countViews ,0);
  var totalCountComments = arr.reduce( (acc, el) => acc+el.countComments ,0);
  var totalCountShares = arr.reduce( (acc, el) => acc+el.countShares ,0);
  var totalCountLikes = arr.reduce( (acc, el) => acc+el.countLikes ,0);
  var trSum = document.createElement('tr');
  trSum.id = "tr_tot_sum";

  var tdNameSum =  document.createElement('td');
  tdNameSum.id = "tdname_tot_sum";
  tdNameSum.innerHTML = "<b>Sum:</b>";

  var tdCountSumComments =  document.createElement('td');
  tdCountSumComments.id = "tdCount_tot_sum_comments";
  tdCountSumComments.innerHTML = "<b>"+totalCountComments+"</b>";

  var tdCountSumShares =  document.createElement('td');
  tdCountSumShares.id = "tdCount_tot_sum_comments";
  tdCountSumShares.innerHTML = "<b>"+totalCountShares+"</b>";

  var tdCountSumLikes =  document.createElement('td');
  tdCountSumLikes.id = "tdCount_tot_sum_likes";
  tdCountSumLikes.innerHTML = "<b>"+totalCountLikes+"</b>";

  var tdCountSumViews =  document.createElement('td');
  tdCountSumViews.id = "tdCount_tot_sum_likes";
  tdCountSumViews.innerHTML = "<b>"+totalCountViews+"</b>";


  trSum.appendChild(tdNameSum);
  trSum.appendChild(tdCountSumComments);
  trSum.appendChild(tdCountSumShares);
  trSum.appendChild(tdCountSumLikes);
  trSum.appendChild(tdCountSumViews);

  rootEl.appendChild(trSum);

  arr.map( (el, elIndex) => {
    var trEl = document.createElement('tr');
    trEl.id = "tr_tot_"+elIndex;

    var tdName =  document.createElement('td');
    tdName.id = "tdname_tot_"+elIndex;
    tdName.innerHTML = el.name;

    var tdCountComments =  document.createElement('td');
    tdCountComments.id = "tdCountComments_tot_"+elIndex;
    tdCountComments.innerHTML = el.countComments;

    var tdCountShares =  document.createElement('td');
    tdCountShares.id = "tdCountComments_tot_"+elIndex;
    tdCountShares.innerHTML = el.countShares;

    var tdCountLikes =  document.createElement('td');
    tdCountLikes.id = "tdCountLikes_tot_"+elIndex;
    tdCountLikes.innerHTML = el.countLikes;

    var tdCountViews =  document.createElement('td');
    tdCountViews.id = "tdCountViews_tot_"+elIndex;
    tdCountViews.innerHTML = el.countViews;

    trEl.appendChild(tdName);
    trEl.appendChild(tdCountComments);
    trEl.appendChild(tdCountShares);
    trEl.appendChild(tdCountLikes);
    trEl.appendChild(tdCountViews);
    rootEl.appendChild(trEl);
  });
};

var normaliseOkDataObj = function (dataObj) {
  const isDeleted = dataObj.status === "deleted";
  const isPrivate = dataObj.status === "blocked";
  const noStats = !dataObj.stats;
  const noComments = noStats ? true : !dataObj.stats.comments;
  const hasTitle = dataObj.title.length;
  const uploadDate = noStats ? "" : dataObj.upload_date.split(/T/).join(" / ");
  const name = hasTitle
    ? dataObj.title.split(/!!!!!/g)[0]
    : (
        isPrivate
        ? '[Private Group]'
        : (
            (isDeleted && noStats)
            ? '[Deleted]'
            : '[Deleted Private]'
          )
    );
  const groupName =
    noStats
    ? "[Deleted]"
    : `<a href="https://ok.ru/search?st.mode=Groups&st.grmode=Groups&st.posted=set&st.query=${dataObj.login}">${dataObj.login}</a>`;

  const cntViews  = noStats ? 0  : parseInt(dataObj.stats.views_total);
  const cntLikes  = noStats ? 0  : (!!dataObj.stats.likes ? parseInt(dataObj.stats.likes) : 0) ;
  const cntShares = (noStats || !dataObj.stats.shares) ? 0 : parseInt(dataObj.stats.shares);
  const cntComments  = (noStats || noComments) ? 0 : parseInt(dataObj.stats.comments);
  const thumb = (isDeleted || isPrivate) ? "" : `<img src=${dataObj.thumbnail} class="thumb"/>`;
  // console.log(dataObj.content_id);
  return {
    "isDeleted": isDeleted,
    "isPrivate": isPrivate,
    "name": name,
    "thumb" : thumb,
    "groupName": groupName,
    "cntViews":  cntViews,
    "cntLikes" : cntLikes,
    "cntShares" : cntShares,
    "cntComments" : cntComments,
    "uploadDate": uploadDate
  };
};

var loadJsonData = function (callback, id) {
  var xobj = new XMLHttpRequest();
  xobj.overrideMimeType("application/json");
  var url = window.location.origin + '/getmovieprops.php?mvid='+id;
  xobj.open('GET', url, true);
  xobj.onreadystatechange = function () {
    if (xobj.readyState == 4 && xobj.status == "200") {
      const dataObj = normaliseOkDataObj(JSON.parse(xobj.responseText))
      callback(id, dataObj);
    } else {
      // console.log(url);
    }
  };
  xobj.send(null);
};

const okFetch = (cb, id, retriesCount = 0) => {
  const movieUrl = 'https://ok.ru/video/' + id;
  const groupNameSelector = 'div.ucard_info > div.ucard_add-info_i.ellip > span > a';
  const viewsSelector = "span.vp-layer-info_i.vp-layer-info_views";
  const commentsSelector = 'a[data-module*="CommentWidgets"] span.widget_count.js-count';
  const sharesSelector = 'button[data-type="RESHARE"] span.widget_count.js-count';
  const likesSelector = 'span.js-klass span.js-count';
  const uploadDateSelector = 'span.vp-layer-info_i.vp-layer-info_date';
  const deletedVideoMsgSelector = '#vp_cnt > div.vp-layer_stub > div > div > div';
  const defaultObj = {
    "isDeleted": true,
    "isPrivate": false,
    "name": '[Deleted]',
    "thumb" : '' ,
    "groupName": '[Deleted]',
    "cntViews":  0,
    "cntLikes" : 0,
    "cntShares" : 0,
    "cntComments" : 0,
    "uploadDate": '',
  };
  setTimeout( () => {
    fetch(movieUrl)
    .then(r => r.text())
    .then(html => {
      const parser = new DOMParser();
      const doc = parser.parseFromString(html, "text/html");
      const isDeleted = !doc.querySelector(commentsSelector);
      if (html.length < 10 && retriesCount <= 3) {
        okFetch(cb, id, retriesCount + 1);
        return;
      }
      if (isDeleted) {
        const deletedVideoMsg = doc.querySelector(deletedVideoMsgSelector).textContent;
        const isPrivate = /групп|group/i.test(deletedVideoMsg);
        defaultObj.name = deletedVideoMsg;
        defaultObj.isPrivate = isPrivate;
        defaultObj.groupName = isPrivate ? '[Private]' : '[Deleted]'
        return cb(id, defaultObj);
      }
      const cntComments = parseInt(doc.querySelector(commentsSelector).textContent);
      const cntShares = parseInt(doc.querySelector(sharesSelector).textContent);
      const cntLikes = parseInt(doc.querySelector(likesSelector).textContent);
      const movieMetadata = JSON.parse(JSON.parse(doc.querySelector('[data-module="OKVideo"]').dataset.options).flashvars.metadata);
      const name = movieMetadata.movie.title;
      // console.log(movieMetadata);
      const thumbUrl = movieMetadata.movie.poster;
      const thumb = `<img src="${thumbUrl}" class="thumb" />`;
      const cntViews = parseInt(doc.querySelector(viewsSelector).textContent.replace(/[\D]/g, ''));
      const groupName = doc.querySelector(groupNameSelector).textContent;
      const groupNameHref = doc.querySelector(groupNameSelector).href;
      const uploadDate = doc.querySelector(uploadDateSelector).textContent;
      const groupNameElement = `<a href="${groupNameHref}">${groupName}</a>`;
      const data = {
        "isDeleted": false,
        "isPrivate": false,
        name,
        thumb,
        "groupName" : groupNameElement,
        cntViews,
        cntLikes,
        cntShares,
        cntComments,
        uploadDate,
      };
      return cb(id, data);
    });
  }, 2000);
}

var drawTable = function () {
  var ids = getMvsIds();
  ids.map( id => {
    var rootEl = document.getElementById('tbodyviews');
    var trEl = document.createElement('tr');
    trEl.id = "tr_"+id;

    var tdDate =  document.createElement('td');
    tdDate.id = "tddate_"+id;
    tdDate.className="small";

    var tdGrpName =  document.createElement('td');
    tdGrpName.className = "group_name";
    tdGrpName.id = "tdgrpname_"+id;

    var tdThumb =  document.createElement('td');
    tdThumb.id = "tdthumb_"+id;

    var tdName =  document.createElement('td');
    tdName.id = "tdname_"+id;
    tdName.className = "movie_name";

    var tdUrl =  document.createElement('td');
    tdUrl.id = "tdurl_"+id;
    tdUrl.className = "movie_url";
    tdUrl.innerHTML = 'https://ok.ru/video/'+id;

    var tdCountViews =  document.createElement('td');
    tdCountViews.id = "tdCountViews_" + id;

    var tdCountShares =  document.createElement('td');
    tdCountShares.id = "tdCountShares_"+id;

    var tdCountComments =  document.createElement('td');
    tdCountComments.id = "tdCountComments_"+id;

    var tdCountLikes =  document.createElement('td');
    tdCountLikes.id = "tdCountLikes_"+id;

    trEl.appendChild(tdDate);
    trEl.appendChild(tdGrpName);
    trEl.appendChild(tdThumb);
    trEl.appendChild(tdName);
    trEl.appendChild(tdUrl);
    trEl.appendChild(tdCountComments);
    trEl.appendChild(tdCountLikes);
    trEl.appendChild(tdCountShares);
    trEl.appendChild(tdCountViews);
    rootEl.appendChild(trEl);
  })
};

var accoumCounter = function(){};

var processTable = function() {
  accoumCounter = countMovieTotals();
  const isOkSite = location.href.includes('ok.ru');
  const curDataFetch = (cb, id) => isOkSite ? okFetch(cb, id) : loadJsonData(cb, id);

  getMvsIds().map( id => {
    curDataFetch(updateTableElement, id)
  });

  new Tablesort(document.getElementById('movies-table-id'), {
    descending: true
  });
};

function selectElementContents(el) {
  var body = document.body, range, sel;
  if (document.createRange && window.getSelection) {
    range = document.createRange();
    sel = window.getSelection();
    sel.removeAllRanges();
    try {
      range.selectNodeContents(el);
      sel.addRange(range);
    } catch (e) {
      range.selectNode(el);
      sel.addRange(range);
    }
    document.execCommand("copy");
    sel.removeAllRanges();
  } else if (body.createTextRange) {
    range = body.createTextRange();
    range.moveToElementText(el);
    range.select();
    range.execCommand("Copy");
  }
  return false;
}

document.getElementById('btn-process').addEventListener('click', processTable);
document.getElementById('listofmovies').addEventListener('change', drawTable);
document.getElementById('btn-copy').addEventListener('click', () => selectElementContents(document.getElementById('movies-table-id')));
document.getElementById('btn-copy-sum').addEventListener('click', () => selectElementContents(document.getElementById('movies-summary')));
document.getElementById('btn-reload').addEventListener('click', () => location.reload());
</file>

<file path="public/getmovieprops.php">
<?php
/**
 * Video stats API
 *
 * PHP Version 7
 *
 * @category None
 * @package  None
 * @author   Anatoliy Poloz <[email protected]>
 * @license  https://www.freebsd.org/copyright/freebsd-license.html BSD
 * @link     http://localhost
 */

require_once __DIR__ . '/vendor/autoload.php';
require_once __DIR__ . '/lib/video-updates.php';

$dotenv = Dotenv\Dotenv::createImmutable(__DIR__ . '/../');
$dotenv->load();
$dsn = "mysql:host=" . $_ENV['MYSQL_HOST']
    .";dbname=" . $_ENV['MYSQL_DATABASE']
    .";charset=UTF8";

$pdo = new PDO($dsn, $_ENV['MYSQL_USER'], $_ENV['MYSQL_PASSWORD']);
$fluent = new \Envms\FluentPDO\Query($pdo);
$fullSiteStats = [];

$movie_id = intval($_GET["mvid"]);
$movieXmlUrl = "https://ok.ru/web-api/videoyandexfeed/" . $movie_id;
$movieFullSiteUrl = "https://ok.ru/video/" . $movie_id;
$xml = file_get_contents($movieXmlUrl);
$domEl = new SimpleXMLElement($xml);

$ovs = json_decode(
    json_encode($domEl->children('ovs', true))
);

$stats = json_decode(
    json_encode(@$domEl->xpath("//*[local-name()='stats']")[0]),
    true
);

$fullSiteStats['authorName'] = false;

if (in_array($ovs->status, ['published', 'blocked'])) {
    $fullSiteStats = getStatsFromFullSiteVersion(
        $_ENV['COOKIES'],
        $movieFullSiteUrl
    );
}

if ($fullSiteStats['authorName'] != false) {
    $ovs->stats = array_merge($stats, $fullSiteStats);
} else {
    $ovs->stats = $stats;
}

/* $ovs->fullSiteStats = $fullSiteStats; */
$json_stats = json_encode($ovs);
updateVideoStats($json_stats, $fluent);
$result = getLastRegisteredVideoStat($json_stats, $fluent);
header('Content-Type: application/json');
echo $result;
</file>

<file path="public/lib/video-updates.php">
<?php
/**
 * Video stats update helper functions
 *
 * PHP Version 7
 *
 * @category Library
 * @package  OkVideoStats
 * @author   Anatoliy Poloz <[email protected]>
 * @license  https://www.freebsd.org/copyright/freebsd-license.html BSD
 * @link     http://localhost
 */

/**
 * Insert last state to videos_readings table
 *
 * @param string $data   is a json string from outer fetch function
 * @param object $fluent fluent state object
 *
 * @return array [$data, $videoInsertStatus, $insStatus] returnin same input
 * string if no exceptions video insertion status and record insertion status
 */
function updateVideoStats($data, $fluent)
{
    $obj = json_decode($data, true);
    $obj['login'] = @mb_strlen($obj['login']) ? $obj['login'] : '';
    $id = $obj['content_id'];
    $isIdExists = $fluent->from('videos')->where('id', $id)->limit(1)->fetch();
    if (!$isIdExists) {
        $video_title = mb_substr($obj['title'], 0, 255, 'utf-8') ?? '';
        $videos_values = [
            'id' => $id,
            'video_title' => $video_title,
            'description' => ''
        ];
        $videoInsert = $fluent->insertInto('videos')->values($videos_values);
        $videoInsertStatus = $videoInsert->execute();
    }
    $videos_readings_values = [
        'video_id' => $id,
        'reading_value' => json_encode($obj)
    ];
    $ins = $fluent->insertInto('videos_readings')->values($videos_readings_values);
    $insStatus = $ins->execute();
    return [$data, ($videoInsertStatus ?? 'ok'), $insStatus];
}

/**
 * Gets last state to videos_readings table
 *
 * @param string $data   is a json string from outer fetch function
 * @param object $fluent fluent state object
 *
 * @return string $data last data in table
 */
function getLastRegisteredVideoStat($data, $fluent)
{
    $obj = json_decode($data, true);
    $id = $obj['content_id'];
    $query = $fluent->from('videos_readings')
        ->select(null)
        ->select(['id','reading_value'])
        ->where('video_id', $id)
        ->where('not status_virtual', 'deleted')
        ->orderBy('date_created desc')
        ->limit(1);
    $queryResult = $query->fetch('reading_value');
    $json = (!$queryResult) ? $data : $queryResult;
    $resultObj = json_decode($json, true);

    if ($obj['status'] === 'deleted') {
        $resultObj['status'] = 'deleted';
    }

    return json_encode($resultObj);
}

/**
 * Update deleted videos stats from data table
 *
 * @param object $pdo pdo initiated object
 *
 * @return any
 */
function updateDeletedVideosStats($pdo)
{
    $sql = 'update videos
        set status="deleted"
        where id in (
            select distinct video_id
            from videos_readings
            where status_virtual="deleted"
        )';
    $pdo->query($sql);
}

/**
 * Get list of 1 hour ago or greater updated movies
 *
 * @param object $pdo configured pdo object
 *
 * @return array
 * */
function getRecentlyUnupdatedClips($pdo)
{
    $sql = 'select max(vr.id) as max_id,
          max(vr.date_created) as last_date,
          vr.video_id from videos_readings vr
          join videos vs
          where vs.id = vr.video_id and vs.status != \'deleted\'
          group by video_id
          having last_date <= NOW() - INTERVAL 1 HOUR';
    return $pdo->query($sql)->fetchAll(PDO::FETCH_ASSOC);
}

/**
 * Get video stats from site full version
 *
 * @param string $cookies  string of cookies including auth
 * @param string $videoUrl url of full site video version
 *
 * @return array
 * */
function getStatsFromFullSiteVersion($cookies, $videoUrl)
{
    /* $opts = array(
        'http' => array(
            'method' => "GET",
            'header' => "Accept-language: en\r\n" .
            $cookies . "\r\n"
        )
    ); */
    $opts = array(
        'http' => array(
            'method' => "GET",
            'header' => "Accept-language: en\r\n"
        )
    );
    $context = stream_context_create($opts);
    $html = file_get_contents($videoUrl, false, $context);

    $dom = new DOMDocument();
    @$dom->loadHtml($html);
    $xpathQueryViews = '//span[contains(@class, "vp-layer-info_views")]';
    $xpathQueryComments = '//a[@data-module="CommentWidgets"]/span[@class="widget_count js-count"]';
    $xpathQueryShares = '//button[@data-type="RESHARE"]/span[@class="widget_count js-count"]';
    $xpathQueryLikes = '//a[contains(@class, "feed_info_sm __reactions")][@data-cnt]';
    $xpathQueryOkVideoModule = '//div[@data-module="OKVideo"]/@data-options';
    $xpath = new DOMXpath($dom);
    $nodesViews = count($xpath->query($xpathQueryViews))
        ? preg_replace('/[\D]/u', '', $xpath->query($xpathQueryViews)[0]->textContent)
        : false;
    $nodesComments = count($xpath->query($xpathQueryComments)) ?
        $xpath->query($xpathQueryComments)[0]->textContent
        : false;
    $nodesShares = count($xpath->query($xpathQueryShares)) ?
        $xpath->query($xpathQueryShares)[0]->textContent
        : false;
    $nodesLikes = count($xpath->query($xpathQueryLikes)) ?
        intval(preg_replace('/[^0-9]+/', '', $xpath->query($xpathQueryLikes)[0]->textContent), 10)
        : 0;
    $okVideoOpts = count($xpath->query($xpathQueryOkVideoModule)) ?
        json_decode($xpath->query($xpathQueryOkVideoModule)[0]->value, true)
        : false;
    $okVideoMetadata = $okVideoOpts ?
        json_decode($okVideoOpts['flashvars']['metadata'], true)
        : false;

    $result = [
        'views' => $nodesViews,
        'comments' => $nodesComments,
        'shares' => $nodesShares,
        'likes' => $nodesLikes,
        'groupUrl' => (
            $okVideoMetadata
            ? "https://ok.ru/group/" . $okVideoMetadata['movie']['groupId'] . "/"
            : false ),
        'authorProfile' => (
            $okVideoMetadata
            ? "https://ok.ru" . $okVideoMetadata['author']['profile']
            : false) ,
        'authorName' => (
            $okVideoMetadata
            ? $okVideoMetadata['author']['name']
            : false)
    ];
    return $result;
}
</file>

<file path="mysql_seed/create_db.sql">
CREATE TABLE `videos` (
  `id` bigint(20) unsigned NOT NULL AUTO_INCREMENT,
  `video_title` varchar(255) NOT NULL,
  `description` varchar(255) NOT NULL,
  `date_created` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP,
  `status` varchar(20) NOT NULL DEFAULT 'hz',
  PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=3910427871745 DEFAULT CHARSET=utf8;

CREATE TABLE `videos_readings` (
  `id` bigint(20) unsigned NOT NULL AUTO_INCREMENT,
  `video_id` bigint(20) unsigned NOT NULL,
  `date_created` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP,
  `reading_value` json NOT NULL,
  `content_id_virtual` bigint(20) GENERATED ALWAYS AS (json_unquote(json_extract(`reading_value`,'$.content_id'))) VIRTUAL NOT NULL,
  `status_virtual` varchar(20) GENERATED ALWAYS AS (json_unquote(json_extract(`reading_value`,'$.status'))) VIRTUAL NOT NULL,
  `login_virtual` varchar(4096) GENERATED ALWAYS AS (json_unquote(json_extract(`reading_value`,'$.login'))) VIRTUAL NOT NULL,
  PRIMARY KEY (`id`),
  KEY `video_id` (`video_id`),
  CONSTRAINT `videos_readings_ibfk_1` FOREIGN KEY (`video_id`) REFERENCES `videos` (`id`) ON DELETE CASCADE
) ENGINE=InnoDB AUTO_INCREMENT=1924 DEFAULT CHARSET=utf8;
</file>

<file path="phpdocker/php-fpm/Dockerfile">
FROM phpdockerio/php74-fpm:latest
WORKDIR "/application"

# Fix debconf warnings upon build
ARG DEBIAN_FRONTEND=noninteractive

# Install selected extensions and other stuff
RUN apt-get update \
    && apt-get -y --no-install-recommends install  php7.4-mysql php7.4-pgsql \
    && apt-get clean; rm -rf /var/lib/apt/lists/* /tmp/* /var/tmp/* /usr/share/doc/*

# Install git
RUN apt-get update \
    && apt-get -y install git \
    && apt-get clean; rm -rf /var/lib/apt/lists/* /tmp/* /var/tmp/* /usr/share/doc/*
</file>

<file path="Makefile">
include .env

stop:
	docker-compose -f docker-compose.yml down
start:
	docker-compose -f docker-compose.yml up -d
status:
	docker-compose -f docker-compose.yml ps
logs:
	docker-compose -f docker-compose.yml logs --tail=10 -f
setup:
	mkdir mysql_data mysql_socks mysql_logs;chmod 777 mysql_data mysql_socks mysql_logs; mv env.example .env
mysql:
	docker-compose exec mysql mysql -p${MYSQL_ROOT_PASSWORD} videostats
restart: stop start
</file>

<file path=".gitignore">
.env
mysql_data/*
mysql_data
mysql_socks/
mysql_socks/*
*~
node_modules/
vendor/
</file>

truncation:
{'is_truncated': False, 'requested_paths': ['phpdocker/php-fpm/Dockerfile', 'composer.json', '.gitignore', 'env.example'], 'omitted_paths': [], 'missed_file_paths': [], 'message_ru': 'No truncation. All requested files were included within limits.'}