blob: 9890358f7a4c6801f4540801e48d7753e5e353d5 (
plain)
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
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
|
package JWebmail::Plugin::ServerSideSessionData;
use Mojo::Base 'Mojolicious::Plugin';
use Mojo::JSON qw(decode_json encode_json);
use Mojo::File;
use constant {
S_KEY => 's3d.key',
};
has '_session_directory';
sub session_directory { my $self = shift; @_ ? $self->_session_directory(Mojo::File->new(@_)) : $self->_session_directory }
has 'expiration';
has 'cleanup_interval';
has '_cleanup';
sub cleanup {
my $self = shift;
if (@_) {
return $self->_cleanup(@_);
}
else {
if ($self->_cleanup < time) {
return 0;
}
else {
$self->_cleanup(time + $self->cleanup_interval);
return 1;
}
}
}
sub s3d {
my $self = shift;
my $c = shift;
# cleanup old sessions
if ($self->cleanup) {
my $t = time;
for ($self->session_directory->list->each) {
if ( $_->stat->mtime + $self->expiration < $t ) {
$_->remove;
}
}
}
my $file = $self->session_directory->child($c->session(S_KEY) || $c->req->request_id . $$);
if (-e $file) {
if ($file->stat->mtime + $self->expiration < time) {
$file->remove;
}
else {
$file->touch;
}
}
my $data = decode_json($file->slurp) if (-s $file);
my ($key, $val) = @_;
if (defined $val) { # set
unless (-e $file) {
$c->session(S_KEY, $file->basename);
}
$data = ref $data ? $data : {};
$data->{$key} = $val;
#$file->spurt(encode_json $data);
open(my $f, '>', $file) or die "$!";
chmod 0600, $f;
$f->say(encode_json $data);
close($f);
}
else { # get
return defined $key ? $data->{$key} : $data;
}
};
sub register {
my ($self, $app, $conf) = @_;
$self->session_directory($conf->{directory} || "/tmp/" . $app->moniker);
$self->expiration($conf->{expiration} || $app->sessions->default_expiration);
$self->cleanup_interval($conf->{cleanup_interval} || $self->expiration);
$self->cleanup(time + $self->cleanup_interval);
unless (-d $self->session_directory) {
mkdir($self->session_directory)
or $! ? die "failed to create directory: $!" : 1;
}
$app->helper( s3d => sub { $self->s3d(@_) } );
}
1
__END__
=encoding utf-8
=head1 NAME
ServeSideSessionData - Stores session data on the server (alias SSSD or S3D)
=head1 SYNOPSIS
$app->plugin('ServeSideSessionData');
$c->s3d(data => 'Hello, S3D');
$c->s3d('data');
=head1 DESCRIPTION
Store data temporarily on the server.
The only protetction on the server are struct user access rights.
=head1 OPTIONS
=head2 directory
default C<< 'tmp/' . $app->moniker >>
=head2 expiration
default session expiration
=head2 cleanup_interval
default session expiration
=head1 HELPERS
=head2 s3d
Stores and retrieves values.
$c->s3d(data => 'Hello, S3D');
$c->s3d('data');
$c->s3d->{data};
=cut
|
