. */ declare(strict_types=1); namespace FireflyIII\Api\V1\Controllers; use FireflyIII\Api\V1\Requests\TransactionStoreRequest; use FireflyIII\Api\V1\Requests\TransactionUpdateRequest; use FireflyIII\Events\StoredTransactionGroup; use FireflyIII\Events\UpdatedTransactionGroup; use FireflyIII\Helpers\Collector\GroupCollectorInterface; use FireflyIII\Models\TransactionGroup; use FireflyIII\Models\TransactionJournal; use FireflyIII\Repositories\Journal\JournalAPIRepositoryInterface; use FireflyIII\Repositories\Journal\JournalRepositoryInterface; use FireflyIII\Repositories\TransactionGroup\TransactionGroupRepositoryInterface; use FireflyIII\Support\Http\Api\TransactionFilter; use FireflyIII\Transformers\AttachmentTransformer; use FireflyIII\Transformers\PiggyBankEventTransformer; use FireflyIII\Transformers\TransactionGroupTransformer; use FireflyIII\User; use Illuminate\Http\JsonResponse; use Illuminate\Http\Request; use League\Fractal\Pagination\IlluminatePaginatorAdapter; use League\Fractal\Resource\Collection as FractalCollection; use League\Fractal\Resource\Item; use Log; use Symfony\Component\HttpKernel\Exception\NotFoundHttpException; /** * Class TransactionController */ class TransactionController extends Controller { use TransactionFilter; /** @var TransactionGroupRepositoryInterface Group repository. */ private $groupRepository; /** @var JournalAPIRepositoryInterface Journal API repos */ private $journalAPIRepository; /** @var JournalRepositoryInterface The journal repository */ private $repository; /** * TransactionController constructor. * * @codeCoverageIgnore */ public function __construct() { parent::__construct(); $this->middleware( function ($request, $next) { /** @var User $admin */ $admin = auth()->user(); $this->repository = app(JournalRepositoryInterface::class); $this->groupRepository = app(TransactionGroupRepositoryInterface::class); $this->journalAPIRepository = app(JournalAPIRepositoryInterface::class); $this->repository->setUser($admin); $this->groupRepository->setUser($admin); $this->journalAPIRepository->setUser($admin); return $next($request); } ); } /** * @param TransactionJournal $transactionJournal * * @return JsonResponse * @codeCoverageIgnore */ public function attachments(TransactionJournal $transactionJournal): JsonResponse { $manager = $this->getManager(); $attachments = $this->journalAPIRepository->getAttachments($transactionJournal); /** @var AttachmentTransformer $transformer */ $transformer = app(AttachmentTransformer::class); $transformer->setParameters($this->parameters); $resource = new FractalCollection($attachments, $transformer, 'attachments'); return response()->json($manager->createData($resource)->toArray())->header('Content-Type', 'application/vnd.api+json'); } /** * Remove the specified resource from storage. * * @param TransactionGroup $transactionGroup * * @return JsonResponse * @codeCoverageIgnore */ public function delete(TransactionGroup $transactionGroup): JsonResponse { $this->repository->destroyGroup($transactionGroup); return response()->json([], 204); } /** * Remove the specified resource from storage. * * @param TransactionJournal $transactionJournal * * @codeCoverageIgnore * @return JsonResponse */ public function deleteJournal(TransactionJournal $transactionJournal): JsonResponse { $this->repository->destroyJournal($transactionJournal); return response()->json([], 204); } /** * Show all transactions. * * @param Request $request * * @return JsonResponse * @codeCoverageIgnore */ public function index(Request $request): JsonResponse { $pageSize = (int)app('preferences')->getForUser(auth()->user(), 'listPageSize', 50)->data; $type = $request->get('type') ?? 'default'; $this->parameters->set('type', $type); $types = $this->mapTransactionTypes($this->parameters->get('type')); $manager = $this->getManager(); /** @var User $admin */ $admin = auth()->user(); // use new group collector: /** @var GroupCollectorInterface $collector */ $collector = app(GroupCollectorInterface::class); $collector ->setUser($admin) // all info needed for the API: ->withAPIInformation() // set page size: ->setLimit($pageSize) // set page to retrieve ->setPage($this->parameters->get('page')) // set types of transactions to return. ->setTypes($types); if (null !== $this->parameters->get('start') && null !== $this->parameters->get('end')) { $collector->setRange($this->parameters->get('start'), $this->parameters->get('end')); } $paginator = $collector->getPaginatedGroups(); $paginator->setPath(route('api.v1.transactions.index') . $this->buildParams()); $transactions = $paginator->getCollection(); /** @var TransactionGroupTransformer $transformer */ $transformer = app(TransactionGroupTransformer::class); $transformer->setParameters($this->parameters); $resource = new FractalCollection($transactions, $transformer, 'transactions'); $resource->setPaginator(new IlluminatePaginatorAdapter($paginator)); return response()->json($manager->createData($resource)->toArray())->header('Content-Type', 'application/vnd.api+json'); } /** * @param TransactionJournal $transactionJournal * * @return JsonResponse * @codeCoverageIgnore */ public function piggyBankEvents(TransactionJournal $transactionJournal): JsonResponse { $manager = $this->getManager(); $events = $this->journalAPIRepository->getPiggyBankEvents($transactionJournal); /** @var PiggyBankEventTransformer $transformer */ $transformer = app(PiggyBankEventTransformer::class); $transformer->setParameters($this->parameters); $resource = new FractalCollection($events, $transformer, 'piggy_bank_events'); return response()->json($manager->createData($resource)->toArray())->header('Content-Type', 'application/vnd.api+json'); } /** * Show a single transaction. * * @param TransactionGroup $transactionGroup * * @return JsonResponse * @codeCoverageIgnore */ public function show(TransactionGroup $transactionGroup): JsonResponse { $manager = $this->getManager(); /** @var User $admin */ $admin = auth()->user(); // use new group collector: /** @var GroupCollectorInterface $collector */ $collector = app(GroupCollectorInterface::class); $collector ->setUser($admin) // filter on transaction group. ->setTransactionGroup($transactionGroup) // all info needed for the API: ->withAPIInformation(); $selectedGroup = $collector->getGroups()->first(); if (null === $selectedGroup) { throw new NotFoundHttpException(); } /** @var TransactionGroupTransformer $transformer */ $transformer = app(TransactionGroupTransformer::class); $transformer->setParameters($this->parameters); $resource = new Item($selectedGroup, $transformer, 'transactions'); return response()->json($manager->createData($resource)->toArray())->header('Content-Type', 'application/vnd.api+json'); } /** * Store a new transaction. * * @param TransactionStoreRequest $request * * @return JsonResponse */ public function store(TransactionStoreRequest $request): JsonResponse { $data = $request->getAll(); $data['user'] = auth()->user()->id; Log::channel('audit') ->info('Store new transaction over API.', $data); $transactionGroup = $this->groupRepository->store($data); event(new StoredTransactionGroup($transactionGroup)); $manager = $this->getManager(); /** @var User $admin */ $admin = auth()->user(); // use new group collector: /** @var GroupCollectorInterface $collector */ $collector = app(GroupCollectorInterface::class); $collector ->setUser($admin) // filter on transaction group. ->setTransactionGroup($transactionGroup) // all info needed for the API: ->withAPIInformation(); $selectedGroup = $collector->getGroups()->first(); if (null === $selectedGroup) { throw new NotFoundHttpException(); // @codeCoverageIgnore } /** @var TransactionGroupTransformer $transformer */ $transformer = app(TransactionGroupTransformer::class); $transformer->setParameters($this->parameters); $resource = new Item($selectedGroup, $transformer, 'transactions'); return response()->json($manager->createData($resource)->toArray())->header('Content-Type', 'application/vnd.api+json'); } /** * Update a transaction. * * @param TransactionUpdateRequest $request * @param TransactionGroup $transactionGroup * * @return JsonResponse */ public function update(TransactionUpdateRequest $request, TransactionGroup $transactionGroup): JsonResponse { Log::debug('Now in update routine.'); $data = $request->getAll(); $transactionGroup = $this->groupRepository->update($transactionGroup, $data); $manager = $this->getManager(); event(new UpdatedTransactionGroup($transactionGroup)); /** @var User $admin */ $admin = auth()->user(); // use new group collector: /** @var GroupCollectorInterface $collector */ $collector = app(GroupCollectorInterface::class); $collector ->setUser($admin) // filter on transaction group. ->setTransactionGroup($transactionGroup) // all info needed for the API: ->withAPIInformation(); $selectedGroup = $collector->getGroups()->first(); if (null === $selectedGroup) { throw new NotFoundHttpException(); // @codeCoverageIgnore } /** @var TransactionGroupTransformer $transformer */ $transformer = app(TransactionGroupTransformer::class); $transformer->setParameters($this->parameters); $resource = new Item($selectedGroup, $transformer, 'transactions'); return response()->json($manager->createData($resource)->toArray())->header('Content-Type', 'application/vnd.api+json'); } }