Skip to content

Commit 944ed0c

Browse files
var77Ngalstyan4
authored andcommitted
remove unnecessarry security definer from functions where there is already grant select to public for underlying tables
1 parent f437643 commit 944ed0c

File tree

1 file changed

+7
-5
lines changed

1 file changed

+7
-5
lines changed

lantern_extras/src/daemon.rs

+7-5
Original file line numberDiff line numberDiff line change
@@ -231,7 +231,6 @@ extension_sql!(
231231
CREATE OR REPLACE FUNCTION get_embedding_job_status(job_id INT)
232232
RETURNS TABLE (status TEXT, progress SMALLINT, error TEXT)
233233
STRICT IMMUTABLE PARALLEL SAFE
234-
SECURITY DEFINER
235234
LANGUAGE plpgsql
236235
AS $$
237236
BEGIN
@@ -259,7 +258,6 @@ extension_sql!(
259258
CREATE OR REPLACE FUNCTION get_completion_job_status(job_id INT)
260259
RETURNS TABLE (status TEXT, progress SMALLINT, error TEXT)
261260
STRICT IMMUTABLE PARALLEL SAFE
262-
SECURITY DEFINER
263261
LANGUAGE plpgsql
264262
AS $$
265263
BEGIN
@@ -277,7 +275,6 @@ extension_sql!(
277275
CREATE OR REPLACE FUNCTION get_completion_job_failures(job_id INT)
278276
RETURNS TABLE (row_id INT, value TEXT)
279277
STRICT IMMUTABLE PARALLEL SAFE
280-
SECURITY DEFINER
281278
LANGUAGE plpgsql
282279
AS $$
283280
BEGIN
@@ -296,7 +293,6 @@ extension_sql!(
296293
CREATE OR REPLACE FUNCTION get_embedding_jobs()
297294
RETURNS TABLE (id INT, status TEXT, progress SMALLINT, error TEXT)
298295
STRICT IMMUTABLE PARALLEL SAFE
299-
SECURITY DEFINER
300296
LANGUAGE plpgsql
301297
AS $$
302298
BEGIN
@@ -316,7 +312,6 @@ extension_sql!(
316312
CREATE OR REPLACE FUNCTION get_completion_jobs()
317313
RETURNS TABLE (id INT, status TEXT, progress SMALLINT, error TEXT)
318314
STRICT IMMUTABLE PARALLEL SAFE
319-
SECURITY DEFINER
320315
LANGUAGE plpgsql
321316
AS $$
322317
BEGIN
@@ -528,6 +523,8 @@ pub mod tests {
528523
"
529524
CREATE TABLE t1 (id serial primary key, title text);
530525
SET lantern_extras.openai_token='test';
526+
CREATE ROLE test_role1;
527+
SET ROLE test_role1;
531528
",
532529
None,
533530
None,
@@ -569,6 +566,8 @@ pub mod tests {
569566
(1, 1, '1test1'),
570567
(1, 2, '1test2'),
571568
(2, 1, '2test1');
569+
CREATE ROLE test_role1;
570+
SET ROLE test_role1;
572571
",
573572
None,
574573
None,
@@ -657,6 +656,7 @@ pub mod tests {
657656
client.update(
658657
"
659658
CREATE TABLE t1 (id serial primary key, title text);
659+
CREATE ROLE test_role1;
660660
",
661661
None,
662662
None,
@@ -666,7 +666,9 @@ pub mod tests {
666666
let id: i32 = id.first().get(1)?.unwrap();
667667

668668
// queued
669+
client.update("SET ROLE test_role1;", None, None,)?;
669670
let rows = client.select("SELECT status, progress, error FROM get_embedding_job_status($1)", None, Some(vec![(PgBuiltInOids::INT4OID.oid(), id.into_datum())]))?;
671+
client.update("RESET ROLE;", None, None,)?;
670672
let job = rows.first();
671673

672674
let status: &str = job.get(1)?.unwrap();

0 commit comments

Comments
 (0)