From 1425d62a31b3601775089cb5951a72d6dc079ec1 Mon Sep 17 00:00:00 2001 From: ad hoc Date: Thu, 9 Jun 2022 18:08:26 +0200 Subject: [PATCH] test dump v5 --- .../tests/assets/v5_v0.28.0_test_dump.dump | Bin 0 -> 5429 bytes meilisearch-http/tests/common/server.rs | 11 ++- meilisearch-http/tests/dumps/data.rs | 5 ++ meilisearch-http/tests/dumps/mod.rs | 71 +++++++++++++++++- 4 files changed, 82 insertions(+), 5 deletions(-) create mode 100644 meilisearch-http/tests/assets/v5_v0.28.0_test_dump.dump diff --git a/meilisearch-http/tests/assets/v5_v0.28.0_test_dump.dump b/meilisearch-http/tests/assets/v5_v0.28.0_test_dump.dump new file mode 100644 index 0000000000000000000000000000000000000000..bc30ea7b91a7f2d0015e3b83f90b03daf0e9843a GIT binary patch literal 5429 zcmbuC!PhB@g(w8s1qkFqGQ?gPOkg57*1IpWN>14xFYgg~f4X_Kpc!Y-8 zA|x|qR3Gsjp_bbjnVc=Zz;dQiraVatfr?FRLXECG00m}(xs6k>uk~s9_g{^$Y0ANd zxbpp-3R7OPN7ccmn}SEM<$Ah#CMHQe|J1Nm1U&W9}34?Vf`%=mkJ9U{apE%MkSi~JmD7CkPyMnw5UFbtJK)>R6S+!23FNhOn z8vg+?uWi}Q4;j*+ik*5R4~-gE!Xy)JVUR~38@d7<@gd>!vLpq9uezihv$vPN! zhLZ{*EW+hMLhSp+0}e;_b42?mANW=-_(?8zk)hwh4QjXZV>B%*XkI5GYOMqEE#UtD zEQ=!NWkMt_SNX)8;1++EKRvf8$0*zWCCLx)dRDb0m4LIz8(bB5HxJ5P5ol`C30PLN>ld@ALA*_b)mWc-pt|RkUEgE*1V`)ztb!&7!vIJ4sC;}AU9btm1 z6?8t7ahqUf?O>|{l;x%z+SWIwVrcQQ=}!_yIC~K;8wObk7SGkd@~H?zQZ;d=DS|{0 zx+zUw)rt3@Ro>c0Lc~;Q=?n($M2h-aCTo$2sQ92HnlHrGAHx&yg=0e2a?OKP-Z6tq zcQ~vb?GJGx+TePK=%sBYsCW!MDt|H*#3Qto$r4eUytJCb`YDTe5xv^Vt*HlPP{6q* z)Cmu{?WAChOPPitWK0-2O)Tu%CH*WRaW-1kh1o8#cr@j<6;yewua_k6%C?1hJ1l(J z+hk5eDP%Pe{DcZZp5102P*84BSg>rm*+UI1xrLHZJ8z=V1RdSeUkF`N3Is ztj~Or)R~BeDjV{Y+pzI)sVcxM{1r7d>XXui$eO7--mYp9edlD14wLXoF3*#ycJUq#Dl8I*lSjChDNGR->GM3wLx5J|qr7#Ah(t>1g-zu91u^ikQe>`d(mLJa#9oH`tjujJR0pi!!((*Gtb$!fZWNWS+J?lOTY|aQKKme9%Tc{FF<47L?>^J6*|9{kjX&$N z(eKEaKa!43;5Id9puC0sIK6a)2=d*2AK6Q;&n1wWh{vQ_&^)7|cO6+|yDrykkLu4P zbX0NJZu(x!FXXDCbdXa4bw7*;Ylw9TZ$>>3)jEUQ@FZa>PUvNsiB zojLSP>_zIvC+Bo=Uhh=3`@@jioNfA-Yq5I9EDKNNNA%1ep! zE3FH|cFj|BzH&`f7I8N|uMQp~{9(KM`7GjS5B4~IvMQ`&(Cv+Ys>fGhx~08VzC`tL zRc#F!0qmA*N}P1$-&gycHu8WF(t?pfFXPZd>)AsF zqJ5DmCvee6b$1xKGttvV9G1qrAMImGj0;pMyELYex=5tSF{%2xC z-{Q*}v^OS@k6QD-XpP{UXd+KY*y(7WVPya7L&5Q)7>?HNcLM2fgE=?yiPD}sG2E)I zLPHjzWzl|RZmWnDrHgUaKeT+zshQMEYQ|!-K+z6PPHq9WgdmC&Z#h>W?!3OmJ9ArF zq-4Y08tU|>qhi(*s5|E>gW4j^O>%ZDGzta* zCK^?Hbk@kBvW&4~3dalgTt~et_9Db)Uh{q{`{K6;9KJ0W=nQXb9OB*N9*~}Y7h(up zaoJm)0K4WK?1dlOF3}7a>wOa~mV`QY?NWCLa@6x!!Cx&-L6J@5BnY!5*v>-I;jR=> zO7!D&-w>j`h`(oB;#;z^14sKIKa1WRkt3EHz&&!M_AiYBm&Xp0ol;`#fg*xqVd{jd z6;)5`nIDHi2VZuH@q<$^WxBCJ*Wa{`wByQk^$eJ1rD8PRnV;HoB^pu z>?oGA-1GSLlS|}Mb&e>C9VMaDHhJU^8MiKs>@DKLK%hjXQb(hQUYiz8_3?nKWTi|0 zU>ceb1xC~8<^!%!$0*I+#6ZZrbw_BKH3e~YYYd)cw9q{;!ox1Z8|CO8mCTA_;LqDA zoF)m0>5!NkcMI8rgqmH@P@M-6rn-4?-QSlgAUO=RN!x0Wu%rBazf@Qw|?;K5~_t;=+}d9s~`loItM)PyP+ZB-*QKEsG zkilH@uRm9tY>@NDR#=pT)^Ze{ft=o>4|7O$affGRevJFOzY0PvN5e|BbDP4WDkBhg zTO;U~pwjGm(f+a_kVTZ^k(fuFfDmj4sV+$-=8Zfu)aFCED=-(vwD#}2KO~7t?V|3K-s;9cD#}>8tQ}ciC4?Fu zn2D(195hA%0b^> zFLh_C?5*f;)>Mnt$4pAx}PiWKR4F}DrSbjKPrQ-9rA z);nUs?%t%2c-G*}_o(xl2b9I~SGpA&D4YuU`!`fS*T}@Qf7iYoAvLJVF`p#VcW(V5 zlux2zfJ!Fr`IcH8eF%H*NJ#qZW*7HFX#( z5)j)K&5T8R{Umox^33r|-eHl%eH3pX_WSHhp=1*3P^U&W^3PhQ(Uza>$c+Uv+qyxTJB zGGDs2T!bYZy~=KukWD>DJUsulw+}x_N`)PzOyF_(O5g}G8*H<5EQ+NpGRJ3lt`s|a zM<+*L*B{J^;PTQ2piY?iJ++Q9Wiu+;eGbMJ#HfmFJx-;1*LJy2%YOLy?cBKxjN~JYuCti^ZBZ_|lT|7!$F@Sr3|bkiRguHyUFIf5 zE$W>g*D6YG7sM6WAwVidNLW*gP!vUOO&MP@_AhFAsb-s zM84=w;*A~WUcI%=x&@(Q;HaN_PiQh8gKV6!XLaQpeyQHSHg99S8e?03FUkd~7 zLeaJ#{3%k_PiBgw>LYcj+L9pEvW<1;g`J?wga9a{i}Sv`9YksbBE>eTBCoQ0wJ zzr6(b!3U39wcD~)mTX91RgOz}Rl@d{XH&2(pDhpNmCLr?>&NKlfOx~U$>)ICOA*;O z$oX4=-^H78&yTeGfc#yi3%DQjRs8r4)^|sFa|a=W!XMA!Br0H|_5VNphp&CtZ^qv6 z`fj-PHk{=Go^}tPcn@~#d!zMdy9f{&yy=xfL(L1l z7-!)oL6notOux`!>#}Qi?6MQU>N?YlH-zcMl?&PHTUE=xB>?CVFvl+Alav5A+;4=a8(RdXQHTJ?oBE>dBY>g6BJ zc~&uIHNq8`}ZqH5(P4Y?K}MHw5T-E2Y(`;Wqa%kJin>f`scfOQ}zsr)I6W)J71jq zZ+k}aTX-p?)kg0;R`tvScSE@X$lRcPOwKCau5ambq?BX3o2({&c44ENV*bvkH-m68 z;G19m=Kibb+v~kt6nyrQ=o)UdsyYj}?ArzjTueahQt#mfhu-ynr3J;V-J0_W81KQ( zl>@rwJYfSwFs*N60*)_M+9!Wmo~$^+wk}wDMEZL(qO*?TinS zw$~cP4cV@Gr-Xy#U4|8fn`M%uP$(|%dqob4nP$+_{diIHw(5cJZ3Zqyn{bKa9Nc54 zv5RM2SPOa7&uY>^+|={0sn&*_<9Xd%+13_Tt^Q;5!qkm3u%JGw27QfqOONeb-7hK9 z3b{;i%59L@K16e2uiBI&!&~>%Z?{K4DtrS%*>#^+#Q?{5H|tg2eqyvfBss&9-$t@E z#v96Tx;b1im3aGFI~qN?$pzH|V|%Zu;;;DVRR3^_o_s29{}JBmU)CO-<@|eT6ECBq za&348{Mp~15KbNR?VT2uw?2xoR*&fuPpZXP+**yDfVEu9mWS8UPtv-Ls-No3>mP|R z_yA6)Xx7X}w`na={X$I)%hgAKA}7BJw%OkLKAu+ggygY+GTx*(>7b34R?F4tQ8LIh z=OUo?t8I2c#?i>15$n=N5~jjB=V>f6WJg#`X=~0`L#Otnjw_2S2%uwBbe2CTJB1Sv5*`4>2^1#ofg=t zj_|%$sm>tazHmE~C5(^sZ`0|ZBd?#aJZ?es(mFljrq*Ms>VFV9z6nSSCW9ilAt3x8 DhaK7& literal 0 HcmV?d00001 diff --git a/meilisearch-http/tests/common/server.rs b/meilisearch-http/tests/common/server.rs index 2dd235e8f..88cacd0ee 100644 --- a/meilisearch-http/tests/common/server.rs +++ b/meilisearch-http/tests/common/server.rs @@ -52,16 +52,13 @@ impl Server { } } - pub async fn new_auth() -> Self { - let dir = TempDir::new().unwrap(); - + pub async fn new_auth_with_options(mut options: Opt, dir: TempDir) -> Self { if cfg!(windows) { std::env::set_var("TMP", TEST_TEMP_DIR.path()); } else { std::env::set_var("TMPDIR", TEST_TEMP_DIR.path()); } - let mut options = default_settings(dir.path()); options.master_key = Some("MASTER_KEY".to_string()); let meilisearch = setup_meilisearch(&options).unwrap(); @@ -79,6 +76,12 @@ impl Server { } } + pub async fn new_auth() -> Self { + let dir = TempDir::new().unwrap(); + let options = default_settings(dir.path()); + Self::new_auth_with_options(options, dir).await + } + pub async fn new_with_options(options: Opt) -> Result { let meilisearch = setup_meilisearch(&options)?; let auth = AuthController::new(&options.db_path, &options.master_key)?; diff --git a/meilisearch-http/tests/dumps/data.rs b/meilisearch-http/tests/dumps/data.rs index a5d7f3426..5df09bfd1 100644 --- a/meilisearch-http/tests/dumps/data.rs +++ b/meilisearch-http/tests/dumps/data.rs @@ -18,6 +18,8 @@ pub enum GetDump { MoviesRawV4, MoviesWithSettingsV4, RubyGemsWithSettingsV4, + + TestV5, } impl GetDump { @@ -63,6 +65,9 @@ impl GetDump { GetDump::RubyGemsWithSettingsV4 => { exist_relative_path!("tests/assets/v4_v0.25.2_rubygems_with_settings.dump").into() } + GetDump::TestV5 => { + exist_relative_path!("tests/assets/v5_v0.28.0_test_dump.dump").into() + } } } } diff --git a/meilisearch-http/tests/dumps/mod.rs b/meilisearch-http/tests/dumps/mod.rs index c26b0e06e..b171330e0 100644 --- a/meilisearch-http/tests/dumps/mod.rs +++ b/meilisearch-http/tests/dumps/mod.rs @@ -1,6 +1,6 @@ mod data; -use crate::common::{default_settings, Server}; +use crate::common::{default_settings, GetAllDocumentsOptions, Server}; use meilisearch_http::Opt; use serde_json::json; @@ -605,3 +605,72 @@ async fn import_dump_v4_rubygems_with_settings() { json!({ "name": "vortex-of-agony", "summary": "You dont need to use nodejs or go, just install this plugin. It will crash your application at random", "description": "You dont need to use nodejs or go, just install this plugin. It will crash your application at random", "id": "159227", "version": "0.1.0", "total_downloads": "1007"}) ); } + +#[actix_rt::test] +async fn import_dump_v5() { + let temp = tempfile::tempdir().unwrap(); + + let options = Opt { + import_dump: Some(GetDump::TestV5.path()), + ..default_settings(temp.path()) + }; + let mut server = Server::new_auth_with_options(options, temp).await; + server.use_api_key("MASTER_KEY"); + + let (indexes, code) = server.list_indexes(None, None).await; + assert_eq!(code, 200, "{indexes}"); + + assert_eq!(indexes["results"].as_array().unwrap().len(), 2); + assert_eq!(indexes["results"][0]["uid"], json!("test")); + assert_eq!(indexes["results"][1]["uid"], json!("test2")); + assert_eq!(indexes["results"][0]["primaryKey"], json!("id")); + + let expected_stats = json!({ + "numberOfDocuments": 10, + "isIndexing": false, + "fieldDistribution": { + "cast": 10, + "director": 10, + "genres": 10, + "id": 10, + "overview": 10, + "popularity": 10, + "poster_path": 10, + "producer": 10, + "production_companies": 10, + "release_date": 10, + "tagline": 10, + "title": 10, + "vote_average": 10, + "vote_count": 10 + } + }); + + let index1 = server.index("test"); + let index2 = server.index("test2"); + + let (stats, code) = index1.stats().await; + assert_eq!(code, 200); + assert_eq!(stats, expected_stats); + + let (docs, code) = index2 + .get_all_documents(GetAllDocumentsOptions::default()) + .await; + assert_eq!(code, 200); + assert_eq!(docs["results"].as_array().unwrap().len(), 10); + let (docs, code) = index1 + .get_all_documents(GetAllDocumentsOptions::default()) + .await; + assert_eq!(code, 200); + assert_eq!(docs["results"].as_array().unwrap().len(), 10); + + let (stats, code) = index2.stats().await; + assert_eq!(code, 200); + assert_eq!(stats, expected_stats); + + let (keys, code) = server.list_api_keys().await; + assert_eq!(code, 200); + let key = &keys["results"][0]; + + assert_eq!(key["name"], "my key"); +}