examples: shouldi: Add golangci-lint operation

Author: Yash-Varshney

CHANGELOG.md

@@ -18,6 +18,7 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
   - Static file serving from a dirctory with `-static`
   - `api.js` file serving with the `-js` flag
   - Docs page for JavaScript example
+- shouldi got an operation to run golangci-lint on Golang code
 ### Fixed
 - Port assignment for the HTTP API via the `-port` flag
 ### Changed

examples/shouldi/shouldi/golangci_lint.py

@@ -0,0 +1,35 @@
+import json
+import asyncio
+from typing import Dict, Any
+
+from dffml.df.base import op
+from dffml.df.types import Definition
+
+package_src_dir = Definition(name="package_src_dir", primitive="str")
+golangci_lint_output = Definition(
+    name="golangci_lint_output", primitive="Dict[str, Any]"
+)
+
+
+@op(inputs={"pkg": package_src_dir}, outputs={"report": golangci_lint_output})
+async def run_golangci_lint(pkg: str) -> Dict[str, Any]:
+    """
+    CLI usage: dffml service dev run -log debug shouldi.golangci_lint:run_golangci_lint -pkg .
+    """
+    proc = await asyncio.create_subprocess_exec(
+        "golangci-lint",
+        "run",
+        "--out-format",
+        "json",
+        pkg,
+        stdout=asyncio.subprocess.PIPE,
+        stderr=asyncio.subprocess.PIPE,
+    )
+    stdout, _stderr = await proc.communicate()
+    if len(stdout) == 0:
+        raise Exception(_stderr)
+
+    golangci_lint_op = stdout.decode()
+    issues = json.loads(golangci_lint_op)
+
+    return {"issues": len(issues["Issues"])}

examples/shouldi/tests/test_golangci_lint.py

@@ -0,0 +1,11 @@
+import os
+
+from dffml.util.asynctestcase import AsyncTestCase
+
+from shouldi.golangci_lint import run_golangci_lint
+
+
+class TestRunGolangci_lintOp(AsyncTestCase):
+    async def test_run(self):
+        results = await run_golangci_lint(os.getcwd())
+        self.assertEqual(type(results["issues"]), int)