Meh

Author: RyanThompson

composer.json

@@ -1,6 +1,6 @@
 {
     "name": "streams/mongodb",
-    "description": "Add MongoDB support to Streams.",
+    "description": "Adds MongoDB support to Streams.",
     "license": "MIT",
     "prefer-stable": true,
     "minimum-stability": "dev",

phpunit.xml

@@ -0,0 +1,26 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<phpunit xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:noNamespaceSchemaLocation="https://schema.phpunit.de/9.3/phpunit.xsd"
+         bootstrap="vendor/autoload.php"
+         colors="true"
+         testdox="true"
+         stopOnFailure="true">
+
+    <coverage>
+        <include>
+            <directory suffix=".php">./src</directory>
+        </include>
+    </coverage>
+
+    <testsuites>
+        <testsuite name="Mongo DB">
+            <directory suffix="Test.php">tests/</directory>
+        </testsuite>
+    </testsuites>
+
+    <php>
+        <ini name="display_errors" value="true"/>
+        <env name="APP_ENV" value="testing"/>
+    </php>
+
+</phpunit>

src/MongoDbAdapter.php

@@ -0,0 +1,97 @@
+<?php
+
+namespace Streams\MongoDb;
+
+use MongoDB\Client;
+use Streams\Core\Stream\Stream;
+use Illuminate\Support\Collection;
+use Streams\Core\Criteria\Adapter\AbstractAdapter;
+
+class MongoDbAdapter extends AbstractAdapter
+{
+    protected $query;
+
+    public function __construct(Stream $stream)
+    {
+        $this->stream = $stream;
+
+        $collection = $stream->config('source.collection');
+
+        $this->client = new Client('mongodb://127.0.0.1:27017');
+    }
+
+    public function orderBy($field, $direction = 'asc'): self
+    {
+        $this->query = $this->query->orderBy($field, $direction);
+
+        return $this;
+    }
+
+    public function limit($limit, $offset = 0): self
+    {
+        $this->query = $this->query->take($limit)->skip($offset);
+
+        return $this;
+    }
+
+    public function where($field, $operator = null, $value = null, $nested = null): self
+    {
+        if (!$value) {
+            $value = $operator;
+            $operator = '=';
+        }
+
+        $method = Str::studly($nested ? $nested . '_where' : 'where');
+
+        $this->query = $this->query->{$method}($field, $operator, $value);
+
+        return $this;
+    }
+
+    public function withTrashed($toggle): self
+    {
+        if ($toggle) {
+            $this->query = $this->query->withTrashed();
+        }
+
+        return $this;
+    }
+
+    public function with($relations): self
+    {
+        $this->query = $this->query->with($relations);
+
+        return $this;
+    }
+
+    public function get(array $parameters = []): Collection
+    {
+        $this->callParameterMethods($parameters);
+
+        return $this->collect($this->query->get());
+    }
+
+    public function count(array $parameters = []): int
+    {
+        $this->callParameterMethods($parameters);
+
+        return $this->query->count();
+    }
+
+    public function save($entry): bool
+    {
+        return $entry->save();
+    }
+
+    public function delete(array $parameters = []): bool
+    {
+        $this->callParameterMethods($parameters);
+        
+        return $this->query->delete();
+    }
+
+    public function truncate(): void
+    {
+        $this->query->truncate();
+    }
+}

src/MongoDbServiceProvider.php

@@ -3,8 +3,14 @@
 namespace Streams\MongoDb;
 
 use Illuminate\Support\ServiceProvider;
+use Streams\Core\Repository\Repository;
 
 class MongoDbServiceProvider extends ServiceProvider
 {
-
+    public function register()
+    {
+        Repository::macro('newMongoAdapter', function() {
+            return new MongoDbAdapter($this->stream);
+        });
+    }
 }

tests/MongoDbAdapterTest.php

@@ -0,0 +1,27 @@
+<?php
+
+namespace Streams\MongoDb\Tests;
+
+use Streams\Core\Support\Facades\Streams;
+use Streams\MongoDb\MongoDbServiceProvider;
+
+class MongoDbAdapterTest extends MongoDbTestCase
+{
+    public function setUp(): void
+    {
+        $this->createApplication();
+
+        Streams::overload('films', [
+            'config' => [
+                'source' => [
+                    'type' => 'mongo',
+                ],
+            ],
+        ]);
+    }
+
+    public function testCanReturnResults()
+    {
+        dd(Streams::make('films')->entries());
+    }
+}

tests/MongoDbTestCase.php

@@ -7,7 +7,6 @@
 
 abstract class MongoDbTestCase extends TestCase
 {
-
     protected function getPackageProviders($app)
     {
         return [MongoDbServiceProvider::class];