anlicheng/dimension_apn
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

init project

Browse Source
This commit is contained in:
anlicheng 2025-04-02 19:46:30 +08:00
commit 4ea17f5e1a
14 changed files with 687 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
.gitignore vendored Normal file
View File

@ -0,0 +1,19 @@
.rebar3
_*
.eunit
*.o
*.beam
*.plt
*.swp
*.swo
.erlang.cookie
ebin
log
erl_crash.dump
.rebar
logs
_build
.idea
*.iml
rebar3.crashdump
*~

191
LICENSE Normal file
View File

@ -0,0 +1,191 @@
Apache License
Version 2.0, January 2004
http://www.apache.org/licenses/
TERMS AND CONDITIONS FOR USE, REPRODUCTION, AND DISTRIBUTION
1. Definitions.
"License" shall mean the terms and conditions for use, reproduction,
and distribution as defined by Sections 1 through 9 of this document.
"Licensor" shall mean the copyright owner or entity authorized by
the copyright owner that is granting the License.
"Legal Entity" shall mean the union of the acting entity and all
other entities that control, are controlled by, or are under common
control with that entity. For the purposes of this definition,
"control" means (i) the power, direct or indirect, to cause the
direction or management of such entity, whether by contract or
otherwise, or (ii) ownership of fifty percent (50%) or more of the
outstanding shares, or (iii) beneficial ownership of such entity.
"You" (or "Your") shall mean an individual or Legal Entity
exercising permissions granted by this License.
"Source" form shall mean the preferred form for making modifications,
including but not limited to software source code, documentation
source, and configuration files.
"Object" form shall mean any form resulting from mechanical
transformation or translation of a Source form, including but
not limited to compiled object code, generated documentation,
and conversions to other media types.
"Work" shall mean the work of authorship, whether in Source or
Object form, made available under the License, as indicated by a
copyright notice that is included in or attached to the work
(an example is provided in the Appendix below).
"Derivative Works" shall mean any work, whether in Source or Object
form, that is based on (or derived from) the Work and for which the
editorial revisions, annotations, elaborations, or other modifications
represent, as a whole, an original work of authorship. For the purposes
of this License, Derivative Works shall not include works that remain
separable from, or merely link (or bind by name) to the interfaces of,
the Work and Derivative Works thereof.
"Contribution" shall mean any work of authorship, including
the original version of the Work and any modifications or additions
to that Work or Derivative Works thereof, that is intentionally
submitted to Licensor for inclusion in the Work by the copyright owner
or by an individual or Legal Entity authorized to submit on behalf of
the copyright owner. For the purposes of this definition, "submitted"
means any form of electronic, verbal, or written communication sent
to the Licensor or its representatives, including but not limited to
communication on electronic mailing lists, source code control systems,
and issue tracking systems that are managed by, or on behalf of, the
Licensor for the purpose of discussing and improving the Work, but
excluding communication that is conspicuously marked or otherwise
designated in writing by the copyright owner as "Not a Contribution."
"Contributor" shall mean Licensor and any individual or Legal Entity
on behalf of whom a Contribution has been received by Licensor and
subsequently incorporated within the Work.
2. Grant of Copyright License. Subject to the terms and conditions of
this License, each Contributor hereby grants to You a perpetual,
worldwide, non-exclusive, no-charge, royalty-free, irrevocable
copyright license to reproduce, prepare Derivative Works of,
publicly display, publicly perform, sublicense, and distribute the
Work and such Derivative Works in Source or Object form.
3. Grant of Patent License. Subject to the terms and conditions of
this License, each Contributor hereby grants to You a perpetual,
worldwide, non-exclusive, no-charge, royalty-free, irrevocable
(except as stated in this section) patent license to make, have made,
use, offer to sell, sell, import, and otherwise transfer the Work,
where such license applies only to those patent claims licensable
by such Contributor that are necessarily infringed by their
Contribution(s) alone or by combination of their Contribution(s)
with the Work to which such Contribution(s) was submitted. If You
institute patent litigation against any entity (including a
cross-claim or counterclaim in a lawsuit) alleging that the Work
or a Contribution incorporated within the Work constitutes direct
or contributory patent infringement, then any patent licenses
granted to You under this License for that Work shall terminate
as of the date such litigation is filed.
4. Redistribution. You may reproduce and distribute copies of the
Work or Derivative Works thereof in any medium, with or without
modifications, and in Source or Object form, provided that You
meet the following conditions:
(a) You must give any other recipients of the Work or
Derivative Works a copy of this License; and
(b) You must cause any modified files to carry prominent notices
stating that You changed the files; and
(c) You must retain, in the Source form of any Derivative Works
that You distribute, all copyright, patent, trademark, and
attribution notices from the Source form of the Work,
excluding those notices that do not pertain to any part of
the Derivative Works; and
(d) If the Work includes a "NOTICE" text file as part of its
distribution, then any Derivative Works that You distribute must
include a readable copy of the attribution notices contained
within such NOTICE file, excluding those notices that do not
pertain to any part of the Derivative Works, in at least one
of the following places: within a NOTICE text file distributed
as part of the Derivative Works; within the Source form or
documentation, if provided along with the Derivative Works; or,
within a display generated by the Derivative Works, if and
wherever such third-party notices normally appear. The contents
of the NOTICE file are for informational purposes only and
do not modify the License. You may add Your own attribution
notices within Derivative Works that You distribute, alongside
or as an addendum to the NOTICE text from the Work, provided
that such additional attribution notices cannot be construed
as modifying the License.
You may add Your own copyright statement to Your modifications and
may provide additional or different license terms and conditions
for use, reproduction, or distribution of Your modifications, or
for any such Derivative Works as a whole, provided Your use,
reproduction, and distribution of the Work otherwise complies with
the conditions stated in this License.
5. Submission of Contributions. Unless You explicitly state otherwise,
any Contribution intentionally submitted for inclusion in the Work
by You to the Licensor shall be under the terms and conditions of
this License, without any additional terms or conditions.
Notwithstanding the above, nothing herein shall supersede or modify
the terms of any separate license agreement you may have executed
with Licensor regarding such Contributions.
6. Trademarks. This License does not grant permission to use the trade
names, trademarks, service marks, or product names of the Licensor,
except as required for reasonable and customary use in describing the
origin of the Work and reproducing the content of the NOTICE file.
7. Disclaimer of Warranty. Unless required by applicable law or
agreed to in writing, Licensor provides the Work (and each
Contributor provides its Contributions) on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
implied, including, without limitation, any warranties or conditions
of TITLE, NON-INFRINGEMENT, MERCHANTABILITY, or FITNESS FOR A
PARTICULAR PURPOSE. You are solely responsible for determining the
appropriateness of using or redistributing the Work and assume any
risks associated with Your exercise of permissions under this License.
8. Limitation of Liability. In no event and under no legal theory,
whether in tort (including negligence), contract, or otherwise,
unless required by applicable law (such as deliberate and grossly
negligent acts) or agreed to in writing, shall any Contributor be
liable to You for damages, including any direct, indirect, special,
incidental, or consequential damages of any character arising as a
result of this License or out of the use or inability to use the
Work (including but not limited to damages for loss of goodwill,
work stoppage, computer failure or malfunction, or any and all
other commercial damages or losses), even if such Contributor
has been advised of the possibility of such damages.
9. Accepting Warranty or Additional Liability. While redistributing
the Work or Derivative Works thereof, You may choose to offer,
and charge a fee for, acceptance of support, warranty, indemnity,
or other liability obligations and/or rights consistent with this
License. However, in accepting such obligations, You may act only
on Your own behalf and on Your sole responsibility, not on behalf
of any other Contributor, and only if You agree to indemnify,
defend, and hold each Contributor harmless for any liability
incurred by, or claims asserted against, such Contributor by reason
of your accepting any such warranty or additional liability.
END OF TERMS AND CONDITIONS
Copyright 2025, anlicheng <244108715@qq.com>.
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.

9
README.md Normal file
View File

@ -0,0 +1,9 @@
dimension_apn
=====
An OTP application
Build
-----
$ rebar3 compile

38
apps/dimension_apn/priv/aps_development.pem Normal file
View File

@ -0,0 +1,38 @@
-----BEGIN CERTIFICATE-----
MIIGkzCCBXugAwIBAgIQYacVGyUDb+FSqLp9ewYcmDANBgkqhkiG9w0BAQsFADB1
MUQwQgYDVQQDDDtBcHBsZSBXb3JsZHdpZGUgRGV2ZWxvcGVyIFJlbGF0aW9ucyBD
ZXJ0aWZpY2F0aW9uIEF1dGhvcml0eTELMAkGA1UECwwCRzQxEzARBgNVBAoMCkFw
cGxlIEluYy4xCzAJBgNVBAYTAlVTMB4XDTI1MDQwMjA4NTk0N1oXDTI2MDUwMjA4
NTk0NlowgYYxJTAjBgoJkiaJk/IsZAEBDBVjb20uamloZS5kaW1lbnNpb25odWIx
OzA5BgNVBAMMMkFwcGxlIFNhbmRib3ggUHVzaCBTZXJ2aWNlczogY29tLmppaGUu
ZGltZW5zaW9uaHViMRMwEQYDVQQLDApQRjNRRzgzN1hTMQswCQYDVQQGEwJDTjCC
ASIwDQYJKoZIhvcNAQEBBQADggEPADCCAQoCggEBALIb4K9MBx+14E0DMOgNpqW1
Dlid/d0w3DNU3H0sJ5MykqEMjXHC3itQfvA+w5bg4KLYR9UdHz596OzsHiuxKJeZ
NjC6xOp7mC63d7qHUI+xHs8dI5URadqldLtRtV+zZNF3DZn2lAbm+UL+Ybu+MSKl
HrZLpSREmUmqRIKpXNcV9IwKMJPFfEAo5aMUzFUO4aAuoGgrT2F/0myb7lyUvxbK
R8W3/BE15f2saCLf4aSiWzZQMtwoiDTEKVBksd+MPDw46L4RDa/hUdHp9GlIh0iT
/MgZSCn1Tk81BJ34fGrHjejtGBEwJZWH8qu1T0OjFRhbhxZ980JizNiKg3LU9mEC
AwEAAaOCAwswggMHMAwGA1UdEwEB/wQCMAAwHwYDVR0jBBgwFoAUW9n6HeeaGguj
mXYiUIY+kchbd6gwcAYIKwYBBQUHAQEEZDBiMC0GCCsGAQUFBzAChiFodHRwOi8v
Y2VydHMuYXBwbGUuY29tL3d3ZHJnNC5kZXIwMQYIKwYBBQUHMAGGJWh0dHA6Ly9v
Y3NwLmFwcGxlLmNvbS9vY3NwMDMtd3dkcmc0MDMwggEeBgNVHSAEggEVMIIBETCC
AQ0GCSqGSIb3Y2QFATCB/zCBwwYIKwYBBQUHAgIwgbYMgbNSZWxpYW5jZSBvbiB0
aGlzIGNlcnRpZmljYXRlIGJ5IGFueSBwYXJ0eSBhc3N1bWVzIGFjY2VwdGFuY2Ug
b2YgdGhlIHRoZW4gYXBwbGljYWJsZSBzdGFuZGFyZCB0ZXJtcyBhbmQgY29uZGl0
aW9ucyBvZiB1c2UsIGNlcnRpZmljYXRlIHBvbGljeSBhbmQgY2VydGlmaWNhdGlv
biBwcmFjdGljZSBzdGF0ZW1lbnRzLjA3BggrBgEFBQcCARYraHR0cHM6Ly93d3cu
YXBwbGUuY29tL2NlcnRpZmljYXRlYXV0aG9yaXR5LzATBgNVHSUEDDAKBggrBgEF
BQcDAjAyBgNVHR8EKzApMCegJaAjhiFodHRwOi8vY3JsLmFwcGxlLmNvbS93d2Ry
ZzQtNS5jcmwwHQYDVR0OBBYEFNpwVOugarBGNv49JwM/dMvG0M4ZMA4GA1UdDwEB
/wQEAwIHgDCBtwYKKoZIhvdjZAYDBgSBqDCBpQwVY29tLmppaGUuZGltZW5zaW9u
aHViMAcMBXRvcGljDBpjb20uamloZS5kaW1lbnNpb25odWIudm9pcDAGDAR2b2lw
DCJjb20uamloZS5kaW1lbnNpb25odWIuY29tcGxpY2F0aW9uMA4MDGNvbXBsaWNh
dGlvbgweY29tLmppaGUuZGltZW5zaW9uaHViLnZvaXAtcHR0MAsMCS52b2lwLXB0
dDAQBgoqhkiG92NkBgMBBAIFADANBgkqhkiG9w0BAQsFAAOCAQEAgpYnPL7ih9Ho
BQitqWa0N8ta++XjmHaT+eumvuk7TujaW8p0mczX+B4aFghhygSuBuFXOcWcrsdd
OcaH+rUzOt60bdtUeh7m9eMqwAuYUUA5EZbDrapEMQvDY9YGsATUOfX/+B2oq74m
DGKTuuiQyWkjALgZKM1xPZvqAOsOskaUB0gKAF2XSJZDasNteNTTrxV8aY+5Pz1v
l9E5Q3Y2wK+9UioB5QKInDghAWLlKxsW2XExWSVZ5TTzlH96VzcMBB0bCOKGzMDQ
8zrQIi8l19O/5K2uBlntYa5N4vAAML11Tjfzh+dXS1X9hFWxFXYz/7sjjtUyHENh
wS+a2gSjmw==
-----END CERTIFICATE-----

32
apps/dimension_apn/priv/priv_key.pem Normal file
View File

@ -0,0 +1,32 @@
Bag Attributes
friendlyName: nanjinjihe
localKeyID: DA 70 54 EB A0 6A B0 46 36 FE 3D 27 03 3F 74 CB C6 D0 CE 19
Key Attributes: <No Attributes>
-----BEGIN PRIVATE KEY-----
MIIEvgIBADANBgkqhkiG9w0BAQEFAASCBKgwggSkAgEAAoIBAQCyG+CvTAcfteBN
AzDoDaaltQ5Ynf3dMNwzVNx9LCeTMpKhDI1xwt4rUH7wPsOW4OCi2EfVHR8+fejs
7B4rsSiXmTYwusTqe5gut3e6h1CPsR7PHSOVEWnapXS7UbVfs2TRdw2Z9pQG5vlC
/mG7vjEipR62S6UkRJlJqkSCqVzXFfSMCjCTxXxAKOWjFMxVDuGgLqBoK09hf9Js
m+5clL8WykfFt/wRNeX9rGgi3+Gkols2UDLcKIg0xClQZLHfjDw8OOi+EQ2v4VHR
6fRpSIdIk/zIGUgp9U5PNQSd+Hxqx43o7RgRMCWVh/KrtU9DoxUYW4cWffNCYszY
ioNy1PZhAgMBAAECggEBAKHV3OHLhkmU/Dtd4+lmxf6ZtnBlFpAOXncx66q9HTSN
5lf5zOgKdc8LtFvd2+DTcqnlNdf6PzKMO8JThdKThdvB9lBu1JBvP0dro5nUbCo0
eVceFf/UM8fdQWUXiGNt4PTHZY95UuW2p9TsyadK2OCvAmoH8AU1Y8dgtCG5fEde
AqaMK6s6/Ib6K+dFbQPx3CjVcom7kC7sJ3pSHQJs4Ze14xy75jin0QC83YWNEOSR
gH2m8OVNF0Jum0pAOnlI0/MAW+L4uPrl+PG+OQQRc1Eq/6OiTQceLMoqHsjIF5UU
TNNxVZQ95PN4uHx1vQq6Vl8iXBxE5VYzSV5OvZA+pQECgYEA15lvZHRTLJVWMfqa
kvbp3mrx07nlaWh9Hv6Mpm8pY9WcvSNtrC7zGvhb0KaXEPh3M2k3FRcToSF3ECjT
D8bDtEzSgS/lBeXJkJdvmfxXjFDCG1+NrjAt2H54pSZV99lkn96fZlFRbTU2Y+Vb
Bx9f3VfJFN9ki/inMu+WG7tedvECgYEA03v6uDZoq2zEwIpOR1eW091Wgph8QUfs
7MJTZZryvE9lmMH6X2jMHwQjMGgzjOr5mLjJsc76W7r0EUvwuTkedCboOcHEB5oW
FmR4PCAFn1UmPGXb1JuSBjd4DcHMDZNgm9p7Hx8mi/hysca+LwQy+ugfs3VJy2Ot
xNmV27QF1nECgYA+ZKL9+UQQxO7668FMArTPrzdoxIWFqb17+MKPb+AUij8f5V7Z
04R7K6C2k19og99LO4m7SsBdgyfHv2jFSgpc5VaOGGQ4/rUEaS7c61ASxVRHQ7Hm
1P6Phpo3gQ6j+X/LXEvY+nOMHTguVLOxLf06OytwJO4eK8mHThqsz96YoQKBgQCN
56fxSZjsRfyzkVo7JruvB9rPoI/noeKJb09UYyczUjdCzA47TO+CdF1EUvccPGMk
pgG4jMCTIpw4qvMo5fnYSG8Uqj7mNu9RMTM4bOg45ILWjiZ2v7i48SleWcaY6WYu
zehFlrpfu2MChPACTlgC4hS7bx0IG6dy6elTVbWBEQKBgEX/6Uk1s9Sne6ksb/0b
/YcDKuDkeTM541+x8YoNe9VOG1hbnYFPmdrxNDzwLZws8ICdwdtfq3GFuBk3pAxp
kRmFNBaoekjvoLnUzPv/mpr/FGz7ZncnyU8d4b0ON+nOrxdt3tR8jOwlIVZkxpyl
kijLSqq+kIwhMfTZytJo57wS
-----END PRIVATE KEY-----

21
apps/dimension_apn/src/dimension_apn.app.src Normal file
View File

@ -0,0 +1,21 @@
{application, dimension_apn,
[{description, "An OTP application"},
{vsn, "0.1.0"},
{registered, []},
{mod, {dimension_apn_app, []}},
{applications,
[
ranch,
cowboy,
lager,
sync,
apns,
kernel,
stdlib
]},
{env,[]},
{modules, []},
{licenses, ["Apache-2.0"]},
{links, []}
]}.

49
apps/dimension_apn/src/dimension_apn_app.erl Normal file
View File

@ -0,0 +1,49 @@
%%%-------------------------------------------------------------------
%% @doc dimension_apn public API
%% @end
%%%-------------------------------------------------------------------
-module(dimension_apn_app).
-behaviour(application).
-export([start/2, stop/1]).
start(_StartType, _StartArgs) ->
start_http_server(),
dimension_apn_sup:start_link().
stop(_State) ->
ok.
%% internal functions
%% 启动http服务
start_http_server() ->
{ok, Props} = application:get_env(dimension_apn, http_server),
Acceptors = proplists:get_value(acceptors, Props, 50),
MaxConnections = proplists:get_value(max_connections, Props, 10240),
Backlog = proplists:get_value(backlog, Props, 1024),
Port = proplists:get_value(port, Props),
Dispatcher = cowboy_router:compile([
{'_', [
{"/api/[...]", http_protocol, [api_handler]},
{"/host/[...]", http_protocol, [host_handler]},
{"/device/[...]", http_protocol, [device_handler]},
{"/totalizator/[...]", http_protocol, [totalizator_handler]},
{"/test/[...]", http_protocol, [test_handler]},
{"/ws", ws_channel, []}
]}
]),
TransOpts = [
{port, Port},
{num_acceptors, Acceptors},
{backlog, Backlog},
{max_connections, MaxConnections}
],
{ok, Pid} = cowboy:start_clear(http_listener, TransOpts, #{env => #{dispatch => Dispatcher}}),
lager:debug("[dimension_apn] the http server start at: ~p, pid is: ~p", [Port, Pid]).

108
apps/dimension_apn/src/dimension_apn_pusher.erl Normal file
View File

@ -0,0 +1,108 @@
%%%-------------------------------------------------------------------
%%% @author anlicheng
%%% @copyright (C) 2025, <COMPANY>
%%% @doc
%%%
%%% @end
%%% Created : 02. 4月 2025 19:09
%%%-------------------------------------------------------------------
-module(dimension_apn_pusher).
-author("anlicheng").
-behaviour(gen_server).
%% API
-export([start_link/0]).
%% gen_server callbacks
-export([init/1, handle_call/3, handle_cast/2, handle_info/2, terminate/2, code_change/3]).
-define(SERVER, ?MODULE).
-record(state, {
}).
%%%===================================================================
%%% API
%%%===================================================================
%% @doc Spawns the server and registers the local name (unique)
-spec(start_link() ->
{ok, Pid :: pid()} | ignore | {error, Reason :: term()}).
start_link() ->
gen_server:start_link({local, ?SERVER}, ?MODULE, [], []).
%%%===================================================================
%%% gen_server callbacks
%%%===================================================================
%% @private
%% @doc Initializes the server
-spec(init(Args :: term()) ->
{ok, State :: #state{}} | {ok, State :: #state{}, timeout() | hibernate} |
{stop, Reason :: term()} | ignore).
init([]) ->
{ok, Pid} = apns:connect(#{
name => my_first_conn,
apple_host => "api.sandbox.push.apple.com",
apple_port => 443,
certfile => "priv/aps_development.pem",
keyfile => "priv/priv_key.pem",
type => cert
}),
lager:debug("connect get pid: ~p", [Pid]),
{ok, #state{}}.
%% @private
%% @doc Handling call messages
-spec(handle_call(Request :: term(), From :: {pid(), Tag :: term()},
State :: #state{}) ->
{reply, Reply :: term(), NewState :: #state{}} |
{reply, Reply :: term(), NewState :: #state{}, timeout() | hibernate} |
{noreply, NewState :: #state{}} |
{noreply, NewState :: #state{}, timeout() | hibernate} |
{stop, Reason :: term(), Reply :: term(), NewState :: #state{}} |
{stop, Reason :: term(), NewState :: #state{}}).
handle_call(_Request, _From, State = #state{}) ->
{reply, ok, State}.
%% @private
%% @doc Handling cast messages
-spec(handle_cast(Request :: term(), State :: #state{}) ->
{noreply, NewState :: #state{}} |
{noreply, NewState :: #state{}, timeout() | hibernate} |
{stop, Reason :: term(), NewState :: #state{}}).
handle_cast(_Request, State = #state{}) ->
{noreply, State}.
%% @private
%% @doc Handling all non call/cast messages
-spec(handle_info(Info :: timeout() | term(), State :: #state{}) ->
{noreply, NewState :: #state{}} |
{noreply, NewState :: #state{}, timeout() | hibernate} |
{stop, Reason :: term(), NewState :: #state{}}).
handle_info(_Info, State = #state{}) ->
{noreply, State}.
%% @private
%% @doc This function is called by a gen_server when it is about to
%% terminate. It should be the opposite of Module:init/1 and do any
%% necessary cleaning up. When it returns, the gen_server terminates
%% with Reason. The return value is ignored.
-spec(terminate(Reason :: (normal | shutdown | {shutdown, term()} | term()),
State :: #state{}) -> term()).
terminate(_Reason, _State = #state{}) ->
ok.
%% @private
%% @doc Convert process state when code is changed
-spec(code_change(OldVsn :: term() | {down, term()}, State :: #state{},
Extra :: term()) ->
{ok, NewState :: #state{}} | {error, Reason :: term()}).
code_change(_OldVsn, State = #state{}, _Extra) ->
{ok, State}.
%%%===================================================================
%%% Internal functions
%%%===================================================================

35
apps/dimension_apn/src/dimension_apn_sup.erl Normal file
View File

@ -0,0 +1,35 @@
%%%-------------------------------------------------------------------
%% @doc dimension_apn top level supervisor.
%% @end
%%%-------------------------------------------------------------------
-module(dimension_apn_sup).
-behaviour(supervisor).
-export([start_link/0]).
-export([init/1]).
-define(SERVER, ?MODULE).
start_link() ->
supervisor:start_link({local, ?SERVER}, ?MODULE, []).
%% sup_flags() = #{strategy => strategy(), % optional
%% intensity => non_neg_integer(), % optional
%% period => pos_integer()} % optional
%% child_spec() = #{id => child_id(), % mandatory
%% start => mfargs(), % mandatory
%% restart => restart(), % optional
%% shutdown => shutdown(), % optional
%% type => worker(), % optional
%% modules => modules()} % optional
init([]) ->
SupFlags = #{strategy => one_for_all,
intensity => 0,
period => 1},
ChildSpecs = [],
{ok, {SupFlags, ChildSpecs}}.
%% internal functions

45
config/sys.config Normal file
View File

@ -0,0 +1,45 @@
[
{dimension_apn, [
{http_server, [
{port, 18080},
{acceptors, 500},
{max_connections, 10240},
{backlog, 10240}
]}
]},
%% 系统日志配置，系统日志为lager, 支持日志按日期自动分割
{lager, [
{colored, true},
%% Whether to write a crash log, and where. Undefined means no crash logger.
{crash_log, "trade_hub.crash.log"},
%% Maximum size in bytes of events in the crash log - defaults to 65536
{crash_log_msg_size, 65536},
%% Maximum size of the crash log in bytes, before its rotated, set
%% to 0 to disable rotation - default is 0
{crash_log_size, 10485760},
%% What time to rotate the crash log - default is no time
%% rotation. See the README for a description of this format.
{crash_log_date, "$D0"},
%% Number of rotated crash logs to keep, 0 means keep only the
%% current one - default is 0
{crash_log_count, 5},
%% Whether to redirect error_logger messages into lager - defaults to true
{error_logger_redirect, true},
%% How big the gen_event mailbox can get before it is switched into sync mode
{async_threshold, 20},
%% Switch back to async mode, when gen_event mailbox size decrease from `async_threshold'
%% to async_threshold - async_threshold_window
{async_threshold_window, 5},
{handlers, [
%% debug | info | warning | error, 日志级别
{lager_console_backend, debug},
{lager_file_backend, [{file, "debug.log"}, {level, debug}, {size, 314572800}]},
{lager_file_backend, [{file, "notice.log"}, {level, notice}, {size, 314572800}]},
{lager_file_backend, [{file, "error.log"}, {level, error}, {size, 314572800}]},
{lager_file_backend, [{file, "info.log"}, {level, info}, {size, 314572800}]}
]}
]}
].

6
config/vm.args Normal file
View File

@ -0,0 +1,6 @@
-sname dimension_apn
-setcookie dimension_apn_cookie
+K true
+A30

46
rebar.config Normal file
View File

@ -0,0 +1,46 @@
{erl_opts, [debug_info]}.
{deps, [
{poolboy, ".*", {git, "https://github.com/devinus/poolboy.git", {tag, "1.5.2"}}},
{hackney, ".*", {git, "https://github.com/benoitc/hackney.git", {tag, "1.16.0"}}},
{sync, ".*", {git, "https://github.com/rustyio/sync.git", {branch, "master"}}},
{cowboy, ".*", {git, "https://github.com/ninenines/cowboy.git", {tag, "2.10.0"}}},
{jiffy, ".*", {git, "https://github.com/davisp/jiffy.git", {tag, "1.1.1"}}},
{mysql, ".*", {git, "https://github.com/mysql-otp/mysql-otp", {tag, "1.8.0"}}},
{parse_trans, ".*", {git, "https://github.com/uwiger/parse_trans", {tag, "3.0.0"}}},
{apns, ".*", {git, "https://github.com/inaka/apns4erl.git", {tag, "2.6.0"}}},
{lager, ".*", {git,"https://github.com/erlang-lager/lager.git", {tag, "3.9.2"}}}
]}.
{relx, [{release, {dimension_apn, "0.1.0"},
[dimension_apn,
sasl]},
{mode, dev},
%% automatically picked up if the files
%% exist but can be set manually, which
%% is required if the names aren't exactly
%% sys.config and vm.args
{sys_config, "./config/sys.config"},
{vm_args, "./config/vm.args"}
%% the .src form of the configuration files do
%% not require setting RELX_REPLACE_OS_VARS
%% {sys_config_src, "./config/sys.config.src"},
%% {vm_args_src, "./config/vm.args.src"}
]}.
{profiles, [{prod, [{relx,
[%% prod is the default mode when prod
%% profile is used, so does not have
%% to be explicitly included like this
{mode, prod}
%% use minimal mode to exclude ERTS
%% {mode, minimal}
]
}]}]}.
{erl_opts, [{parse_transform,lager_transform}]}.
{rebar_packages_cdn, "https://hexpm.upyun.com"}.

82
rebar.lock Normal file
View File

@ -0,0 +1,82 @@
{"1.2.0",
[{<<"apns">>,
{git,"https://github.com/inaka/apns4erl.git",
{ref,"503a51f018b2865908e1c1462a887c617ba3249b"}},
0},
{<<"base64url">>,{pkg,<<"base64url">>,<<"1.0.1">>},1},
{<<"certifi">>,{pkg,<<"certifi">>,<<"2.5.2">>},1},
{<<"cowboy">>,
{git,"https://github.com/ninenines/cowboy.git",
{ref,"9e600f6c1df3c440bc196b66ebbc005d70107217"}},
0},
{<<"cowlib">>,
{git,"https://github.com/ninenines/cowlib",
{ref,"cc04201c1d0e1d5603cd1cde037ab729b192634c"}},
1},
{<<"fs">>,{pkg,<<"fs">>,<<"6.1.1">>},1},
{<<"goldrush">>,{pkg,<<"goldrush">>,<<"0.1.9">>},1},
{<<"gun">>,{pkg,<<"gun">>,<<"2.1.0">>},1},
{<<"hackney">>,
{git,"https://github.com/benoitc/hackney.git",
{ref,"f3e9292db22c807e73f57a8422402d6b423ddf5f"}},
0},
{<<"idna">>,{pkg,<<"idna">>,<<"6.0.1">>},1},
{<<"jiffy">>,
{git,"https://github.com/davisp/jiffy.git",
{ref,"9ea1b35b6e60ba21dfd4adbd18e7916a831fd7d4"}},
0},
{<<"jsx">>,{pkg,<<"jsx">>,<<"3.1.0">>},1},
{<<"lager">>,
{git,"https://github.com/erlang-lager/lager.git",
{ref,"459a3b2cdd9eadd29e5a7ce5c43932f5ccd6eb88"}},
0},
{<<"metrics">>,{pkg,<<"metrics">>,<<"1.0.1">>},1},
{<<"mimerl">>,{pkg,<<"mimerl">>,<<"1.2.0">>},1},
{<<"mysql">>,
{git,"https://github.com/mysql-otp/mysql-otp",
{ref,"caf5ff96c677a8fe0ce6f4082bc036c8fd27dd62"}},
0},
{<<"parse_trans">>,
{git,"https://github.com/uwiger/parse_trans",
{ref,"6f3645afb43c7c57d61b54ef59aecab288ce1013"}},
0},
{<<"poolboy">>,
{git,"https://github.com/devinus/poolboy.git",
{ref,"3bb48a893ff5598f7c73731ac17545206d259fac"}},
0},
{<<"ranch">>,
{git,"https://github.com/ninenines/ranch",
{ref,"a692f44567034dacf5efcaa24a24183788594eb7"}},
1},
{<<"ssl_verify_fun">>,{pkg,<<"ssl_verify_fun">>,<<"1.1.6">>},1},
{<<"sync">>,
{git,"https://github.com/rustyio/sync.git",
{ref,"7dc303ed4ce8d26db82e171dbbd7c41067852c65"}},
0},
{<<"unicode_util_compat">>,{pkg,<<"unicode_util_compat">>,<<"0.5.0">>},2}]}.
[
{pkg_hash,[
{<<"base64url">>, <<"F8C7F2DA04CA9A5D0F5F50258F055E1D699F0E8BF4CFDB30B750865368403CF6">>},
{<<"certifi">>, <<"B7CFEAE9D2ED395695DD8201C57A2D019C0C43ECAF8B8BCB9320B40D6662F340">>},
{<<"fs">>, <<"9D147B944D60CFA48A349F12D06C8EE71128F610C90870BDF9A6773206452ED0">>},
{<<"goldrush">>, <<"F06E5D5F1277DA5C413E84D5A2924174182FB108DABB39D5EC548B27424CD106">>},
{<<"gun">>, <<"B4E4CBBF3026D21981C447E9E7CA856766046EFF693720BA43114D7F5DE36E87">>},
{<<"idna">>, <<"1D038FB2E7668CE41FBF681D2C45902E52B3CB9E9C77B55334353B222C2EE50C">>},
{<<"jsx">>, <<"D12516BAA0BB23A59BB35DCCAF02A1BD08243FCBB9EFE24F2D9D056CCFF71268">>},
{<<"metrics">>, <<"25F094DEA2CDA98213CECC3AEFF09E940299D950904393B2A29D191C346A8486">>},
{<<"mimerl">>, <<"67E2D3F571088D5CFD3E550C383094B47159F3EEE8FFA08E64106CDF5E981BE3">>},
{<<"ssl_verify_fun">>, <<"CF344F5692C82D2CD7554F5EC8FD961548D4FD09E7D22F5B62482E5AEAEBD4B0">>},
{<<"unicode_util_compat">>, <<"8516502659002CEC19E244EBD90D312183064BE95025A319A6C7E89F4BCCD65B">>}]},
{pkg_hash_ext,[
{<<"base64url">>, <<"F9B3ADD4731A02A9B0410398B475B33E7566A695365237A6BDEE1BB447719F5C">>},
{<<"certifi">>, <<"3B3B5F36493004AC3455966991EAF6E768CE9884693D9968055AEEEB1E575040">>},
{<<"fs">>, <<"EF94E95FFE79916860649FED80AC62B04C322B0BB70F5128144C026B4D171F8B">>},
{<<"goldrush">>, <<"99CB4128CFFCB3227581E5D4D803D5413FA643F4EB96523F77D9E6937D994CEB">>},
{<<"gun">>, <<"52FC7FC246BFC3B00E01AEA1C2854C70A366348574AB50C57DFE796D24A0101D">>},
{<<"idna">>, <<"A02C8A1C4FD601215BB0B0324C8A6986749F807CE35F25449EC9E69758708122">>},
{<<"jsx">>, <<"0C5CC8FDC11B53CC25CF65AC6705AD39E54ECC56D1C22E4ADB8F5A53FB9427F3">>},
{<<"metrics">>, <<"69B09ADDDC4F74A40716AE54D140F93BEB0FB8978D8636EADED0C31B6F099F16">>},
{<<"mimerl">>, <<"F278585650AA581986264638EBF698F8BB19DF297F66AD91B18910DFC6E19323">>},
{<<"ssl_verify_fun">>, <<"BDB0D2471F453C88FF3908E7686F86F9BE327D065CC1EC16FA4540197EA04680">>},
{<<"unicode_util_compat">>, <<"D48D002E15F5CC105A696CF2F1BBB3FC72B4B770A184D8420C8DB20DA2674B38">>}]}
].

6
run Executable file
View File

@ -0,0 +1,6 @@
#! /bin/sh
rebar3 compile
rebar3 release
_build/default/rel/dimension_apn/bin/dimension_apn console