FishStore/examples/lib_examples/github_lib.cc at master · microsoft/FishStore · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
// Copyright (c) Microsoft Corporation. All rights reserved.
// Licensed under the MIT license.

#include <cstdio>
#include <iostream>
#include <vector>
#ifdef _WIN32
#define LIBEXPORT_MACROS extern "C" __declspec(dllexport)
#else
#define LIBEXPORT_MACROS extern "C"
#endif
#include "adapters/simdjson_adapter.h"
#include "core/psf.h"

typedef fishstore::adapter::SIMDJsonAdapter adapter_t;
using namespace fishstore::core;

LIBEXPORT_MACROS NullableInt cpp_pr(const std::vector<adapter_t::field_t>& fields) {
  auto type = fields[0].GetAsStringRef();
  auto language = fields[1].GetAsStringRef();
  if(type.HasValue() && strcmp("PullRequestEvent", type.Value().Data()) == 0 &&
     language.HasValue() && strcmp("C++", language.Value().Data()) == 0)
    return NullableInt{false, 1};
  else
    return NullableInt{true, 0};
}

LIBEXPORT_MACROS NullableInt opened_issue(const std::vector<adapter_t::field_t>& fields) {
  auto type = fields[0].GetAsStringRef();
  auto payload_action = fields[1].GetAsStringRef();
  if(type.HasValue() && strcmp("IssuesEvent", type.Value().Data()) == 0 &&
      payload_action.HasValue() && strcmp("opened", payload_action.Value().Data()) == 0) {
    return NullableInt{false, 1};
  } else
    return NullableInt{true, 0};
}

LIBEXPORT_MACROS NullableInt int_projection(const std::vector<adapter_t::field_t>& fields) {
  auto ref = fields[0].GetAsInt();
  if (ref.HasValue()) {
    return NullableInt{ false, ref.Value() };
  }
  else {
    return NullableInt{ true, 0 };
  }
}